Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Kafka - Consumers with different speeds

How to create topic in Kafka with Python-kafka admin client?

Kafka suddenly reset the consumer Offset

Kafka set the maximum number of messages to read from the topic

Send byte array to storm kafka bolt

Join multiple Kafka topics by key

How to acknowledge consume message in kafka using php-rdkafka?

How to detect duplicate messages in a kafka topic?

How do I stop attempting to consume messages off of Kafka when at the end of the log?

Can a kafka consumer group freeze during a rebalance

Kafka having duplicate messages

Spark Streaming from Kafka Consumer

Maximum subscription limit of Kafka Topics Per Consumer

Consumer and producer failing with error: "Connection to 0 was disconnected before the response was read"

What is the difference between MANUAL and MANUAL_IMMEDIATE in spring-kafka AckMode

Kafka: what is the point of using "acknowledgment.nack" if I can simply "not acknowledgment.acknowledge"

How to remove a Kafka consumer group from a specific topic?

Kafka - Consumer group creation with specific offset?

WARN Error while fetching metadata with correlation id 1 : {MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient)

How to set group name when consuming messages in kafka using command line?