Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Kafka consumer does not start from latest message

How to support multiple KeyBy in Flink

How to remove/clear state stores in Kafka Streams?

Counting all entries with KSQL

Kafka Connect can't find connector

Alpakka kafka vs Kafka streams

Kafka High Level Consumer Fetch All Messages From Topic Using Java API (Equivalent to --from-beginning)

apache-kafka java consumer

Kafka unable to connect to Zookeeper

KafkaProducer not successfully sending message into the queue

Simple Kafka Consumer not receiving messages

Why is Kafka consumer ignoring my "earliest" directive in the auto.offset.reset parameter and thus not reading my topic from the absolute first event?

Uneven Distribution of messages in Kafka Partitions

How can I retry failure messages from kafka?

Java consumer group missing?

What makes Kafka high in throughput?

apache-kafka

How Kafka Nodes and zookeeper will communicate with each other?

Rails: How to listen to / pull from service or queue?

Using Kafka Connect HOWTO "commit offsets" as soon as a "put" is completed in SinkTask

How does Kafka guarantee sequential disk access?

apache-kafka

Kafka consumer group offset retention