Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Kafka ByteArray

arrays kafka-consumer-api

Kafka listener receiving List<ConsumerRecord<String, String>>, is it possible to consume?

Kafka balancing load between multiple tenants

Kafka throttle producer based on consumer lag

How to configure kafka consumer with sasl mechanism PLAIN and with security protocol SASL_SSL in java?

Kafka not connecting getting below issue

Using Kafka's Log Compaction, what can I do to guarantee consumers don't miss messages, if they are not lagging behind by some defined timelimit?

How to implement ConsumerSeekAware in Spring-kafka?

How to configure Apache Kafka to sending data at specified time?

Kafka new consumer: (re)set and commit offsets with using assign, not subscribe

How to update Kafka consumer max.request.size config while using Spark structured stream

What is the ideal number of partitions in kafka topic?

Apache Kafka : commitSync after pause