Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Kafka Consumer: No entry found for connection

Why do Kafka consumers output INVALID_FETCH_SESSION_EPOCH after updating to 1.1?

Kafka - Delayed Queue implementation using high level consumer

Kafka - difference between Log end offset(LEO) vs High Watermark(HW)

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?