Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Kafka consumer "failed to find leader" when fetching topic metadata

Does commitOffsets on high-level consumer block?

Kafka Java API offset operations clarification

Kafka Offset after retention period

Does kafka have any default web UI [closed]

Consuming from a replica

How to handle error and don't commit when use Kafka Streams DSL

Delayed message consumption in Kafka

Error creating Kafka topic :- replication factor larger than available brokers

Kafka 0.9 How to re-consume message when manually committing offset with a KafkaConsumer

InstanceAlreadyExistsException coming from kafka consumer

kafka-python - How do I commit a partition?

NoBrokersAvailable: NoBrokersAvailable-Kafka Error

What could cause "Failed to get offsets by times" in a Kafka Consumer?

Kafka consumer reconnection after getting disconnected

Kafka Consumer's poll() method gets blocked

Is it possible to transfer files using Kafka?

How to create separate Kafka listener for each topic dynamically in springboot?

How to Consume from specific TopicPartitionOffset with Confluent.Kafka in .Net

kafka Synchronization :"java.io.IOException: Too many open files"