Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

How to decide the concurrency to be set in spring kafka?

Kafka consumer/partition vs thread/partition relationship

Getting ClassCastException when sending error message to kafka dlq

When reading multiple topics in kafka how can I tell the topic of a specific message?

Kafka-node suddenly consumes from offset 0

Will group cordinator treat kafka consumer (0.9) dead if it doesn't call poll() for a very long time?

kafka-consumer-api

Retry kafka Message Consumption On Database Failure

How to consume messages from Kafka in Java, starting from a specific offset

How to pause a kafka consumer?

Who keeps track of the last read message offset of the consumer in Apache Kafka?

Consumer 'group_name' group is rebalancing forever

How to list Kafka consumer group using python

Why am I getting a ConfigException 'Expected a comma separated list' error when creating a KafkaConsumer

Parallel processing and auto scaling in spring-kafka KafkaListener

Quarkus Kafka Consumer: read from database before starting consuming

How to read messages from kafka consumer group without consuming?

kafka multi-threaded consumer with manual commit offset: KafkaConsumer is not safe for multi-threaded access

How is message sequence preserved for topic with many partitions?

Kafka repartitioning