Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Prevent kafka consumer from timing out for long process

what is best practice to consume messages from multiple kafka topics?

Kafka Streams does not increment offset by 1 when producing to topic

How to consume data from kafka topic in specific offset to specific offset?

fetch.max.wait.ms vs parameter to poll() method

Kafka - What are the better alternatives than poll() to listen to a topic in Java?

How do I set the size of messages in Kafka?

Request messages between two timestamps from Kafka

How to check which partition is a key assign to in kafka?

Consumer Id and Group Id in Kafka: what makes two consumers the same

Not able connect to EventHub via KAFKA api

Who killed My Java Infinite loop thread?

Explain replication-offset-checkpoint AND recovery-point-offset in Kafka

Kafka command line producer/consumer have 1 second latency

Spring Kafka Partitioning

Kafka broker is not available from localhost

How to monitor consumer lag in kafka via jmx?

Is the --group option deprecated from kafka-console-consumer tool? if so, how can I set the consumer group using kafka-console-consumer.

Can a Kafka consumer(0.8.2.2) read messages in batch

Apache Kafka and Avro: org.apache.avro.generic.GenericData$Record cannot be cast to com.harmeetsingh13.java.Customer