Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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

Control enabling/disabling Kafka consumers in Spring Boot

Kafka consumer receiving same message multiple times

Object not serializable (org.apache.kafka.clients.consumer.ConsumerRecord) in Java spark kafka streaming