Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How can I instantiate a Mock Kafka Topic for junit tests?

junit mocking apache-kafka

Kafka error deserializing key/value for partition

Kafka Consumer - Poll behaviour

Good practice when using kafka with jpa

How to filter messages before passing them on to consumers?

java apache-kafka

Difference between heartbeat.interval.ms and session.timeout.ms in Kafka consumer config

How to test whether log compaction is working or not in Kafka?

How to make kafka consumer to read from last consumed offset but not from beginning

Simple Kafka Consumer Example not working

Send Custom Java Objects to Kafka Topic

In Kafka how to get the exact offset according producing time

The group coordinator is not available-Kafka

java apache-kafka

How to fix "java.io.NotSerializableException: org.apache.kafka.clients.consumer.ConsumerRecord" in Spark Streaming Kafka Consumer?

Kafka with .Net Client

Zookeeper issue in setting kafka

Apache Kafka Producer Broker Connection

apache-kafka

Create multiple consumers in Kafka in command line

apache-kafka

How to handle backpressure in a Kafka Connect Sink?

Consume the same message again if processing of the message fails