Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Spring Boot Kafka Consumer throwing No bean named 'kafkaListenerContainerFactory' available

Spring-Kafka usage of ConcurrentKafkaListenerContainerFactory for more than One @Kafkalistener

What does KafkaConsumer.commitSync() actually commit?

Recommended settings for Kafka Internal Topics after upgrade to 1.0

apache-kafka

Kafka Consumer in Node.js

kafka mirrormaker 2 custom partitioner

Understanding of kafka auto-offset-reset

apache-kafka

Serde class for AVRO primitive type

When does Zookeeper change Kafka cluster ID?

Is there a way to start/stop Kafka consumer in a Spring app manually?

How to get Kafka header's value to Spark Dataset as a single column?

Kafka: What do the numbers in controller_epoch and leader_epoch mean?

apache-kafka

How do we map multiple collections to multiple topics in the mongodb-sink-connector?

How to produce a json object message into kafka topic using java(spring)?

scale spring-kafka consumers app horizontally

Kafka Producer: Disconnect after sending message vs keeping connection open

apache-kafka kafkajs

How to recover kafka messages?

apache-kafka recovery

Conditional logic on a Reactor Flux

Kafka Connect failing to read from Kafka topics over SSL

Kafka - How to skip a bad message in an offset and consume the rest

java apache-kafka