Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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"

Kafka optimal retention and deletion policy

Update message in Kafka topic

Terminate Kafka Console Consumer when all the messages have been read

How to connect Kafka with Elasticsearch?