Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Kafka producer throws an error Invalid transition attempted from state IN_TRANSACTION to state IN_TRANSACTION

Difference between Kafka Consumer and Spark-Kafka-Consumer

Is schema registry required with any kafka avro set up?

What is the cleaner and efficient way of implementing health check for Kafka in my spring boot application?

Setting Python KafkaProducer sasl mechanism property

parallelism configuration in trident topology (storm)

unique message check in kafka topic

apache-kafka logstash

Kafka There is no leader for this topic-partition as we are in the middle of a leadership election

Does kafka distinguish between consumed offset and commited offset?

Kafka Connect - metrics through JMX

How to set groupId to null in @KafkaListeners

apache-kafka spring-kafka

Creating kafka topics with Java doesn't work

Is there a way to dump Amazon MSK Topic to S3 directly?

How to get avro schema from schema registry by subject?

Embedded Kafka Test - The Kafka listener is not invoked