Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Unable to produce to Kafka topic that is running on WSL 2 from Windows

When to use ExponentialBackOffPolicy vs FixedBackOffPolicy when setting retry policy for a kafka consumer in a Spring boot app?

apache-kafka spring-kafka

Can Kafka compaction overwrite messages with same partition key?

apache-kafka messaging

How to make a spout wait on another spout?

Kafka Connect and Streams

Apache Kafka - Resetting the last seen epoch of partition. Why?

[HDFS connector + Kafka]How to write multiple topics in standalone mode?

Spring Kafka. Not started EmbeddedKafkaBroker

What is the use of Header in Kafka Processor API?

How to connect to Kafka cluster with Kerberos Authentication on Windows using the Cofluent library?

Is an upsert possible with Kafka Connect to ElasticSearch

Kafka API: java.io.IOException: Can't resolve address: 357d78957cf5:9092

scala apache-kafka