Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Kafka producer TimeoutException: Expiring 1 record(s)

Kafka console consumer ERROR "Offset commit failed on partition"

Counting Number of messages stored in a kafka topic

Kafka consumer offset max value?

Get last message from kafka consumer console script

Docker Kafka w/ Python consumer

understanding consumer group id

Kafka10.1 heartbeat.interval.ms, session.timeout.ms and max.poll.interval.ms

How to get latest offset for a partition for a kafka topic?

Kafka consumer for multiple topic

How does Kafka store offsets for each topic?

Kafka how to read from __consumer_offsets topic

Kafka and firewall rules

Kafka Consumer default Group Id

How to create topics in apache kafka?

How does consumer rebalancing work in Kafka?

What is the difference in Kafka between a Consumer Group Coordinator and a Consumer Group Leader?

How can I get the last/end offset of a kafka topic partition?

Kafka consumer fetching metadata for topics failed

What is the difference between kafka earliest and latest offset values