Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

When to use ConcurrentKafkaListenerContainerFactory?

Kafka Avro Consumer with Decoder issues

No current assignment for partition occurs even after poll in Kafka

how to get the all messages in a topic from kafka server

Is there a way to set a delay for a message sent by a kafka producer?

KafkaConsumer position() vs committed()?

Retry logic in kafka consumer

Error UNKNOWN_MEMBER_ID occurred while committing offsets for group xxx

Problems with the retention period for offset topic of kafka

Spring Kafka Consumer Retry

kafka-python consumer not receiving messages

Consumer Stuck in Re-join

Balancing Kafka consumers

Kafka : How to connect kafka-console-consumer to fetch remote broker topic content?

Kafka Topic vs Partition topic

Kafka Consumer outputs excessive DEBUG statements to console (ecilpse)

Kafka Rebalancing. Duplicate processing issue

org.apache.kafka.common.KafkaException: Failed to construct kafka consumer

How to save latest offset that Spark consumed to ZK or Kafka and can read back after restart

Kafka bootstrap-servers vs zookeeper in kafka-console-consumer