Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Kafka Consumer: How to start consuming from the last message in Python

INFO Closed socket connection for client /127.0.0.1:48452 which had sessionid 0x15698f5ac360001 (org.apache.zookeeper.server.NIOServerCnxn)

Pausing a kafka topic with multiple consumers

Is kafka consumer 0.9 backward compatible?

Kafka multiple partition ordering

Kafka console consumer get partition

How to choose the no of partitions for a kafka topic?

kafka-python consumer start reading from offset (automatically)

kafka consumer sessions timing out

How to pass dynamic topic name to @KafkaListener(topics) from environment variable

Difference between poll and consume in Kafka Confluent library

Kafka keeps rebalancing consumers

Kafka throws java.nio.channels.ClosedChannelException

Avro decoding gives java.io.EOFException

Kafka as a message queue for long running tasks

Kafka Maven Dependencies

Kafka: The message when serialized is larger than the maximum request size you have configured with the max.request.size configuration

Configure kafka-net to stop sending latest messages

kafka consumer group is rebalancing