Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

spring-integration-kafka config consumer to receive message from specify partition

Does Apache Kafka provide an asynchronous subscription callback API?

Kafka 10 kafka-consumer-groups.sh vs. Kafka 8 kafka-run-class.sh of ConsumerOffsetChecker

how to get last committed offset from read_committed Kafka Consumer

Kafka Consumer: Stop processing messages when exception was raised

Kafka Consumer needs a long poll duration

kafka new version 2.1.0 broker hangs for no reason

What is the best practice for keeping Kafka consumer alive in python?

Unable to communicate with kafka server using kafka Producer API

Magic byte in Apache Kafka

How to put data from MySQL to Kafka producer? [closed]

Bidirectional messaging system using kafka

How to set offset in kafkalistener

bootstrap-server vs zookeeper params in consumer console

KafkaConsumer: `seekToEnd()` does not make consumer consume from latest offset