Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in 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

Is Kafka the right solution for messages with dependencies?

How reset a consumer group in kafka?

How do I install an extension of Kafka for PHP?

Spark streaming if(!rdd.partitions.isEmpty) not working