Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Magic byte in Apache Kafka

Kafka and Akka Cluster

How to put data from MySQL to Kafka producer? [closed]

Kafka Streams with lookup data on HDFS

Bidirectional messaging system using kafka

Kafka Streams - what is stored in memory and disk in Streams App

How to set offset in kafkalistener

CQRS: project out-of-order notifications in an ElasticSearch read model

Why does Kafka Direct Stream create a new decoder for every message?

use of "default" in avro schema

Testing window aggregation with Kafka Streams

How can I assure consistency when using an event-carried state transfer approach in Kafka

Kafka JDBC Sink Connector: no tasks assigned

How to send and consume json messages using confluent-kafka in Python

No JAAS configuration section named 'Server' was foundin '/kafka/kafka_2.12-2.3.0/config/zookeeper_jaas.conf'

Kafka stream: "TopicAuthorizationException: Not authorized to access topics" for an internal state store

How can I disable spring cloud stream for development purpose when there are not kafka broker running?

Filter the records by a certain value in kafka connect

Kafka Serialization of an object [duplicate]

Best practice for integrating Kafka and HBase