Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

The group member's supported protocols are incompatible with those of existing members

Spring KafkaListener: How to know when it's ready

Synchronize Data From Multiple Data Sources

AWS MSK - Timeout when creating Kafka topic with ACL turned-on

Message routing in kafka

Kafka 0.10 Java Client TimeoutException: Batch containing 1 record(s) expired

UDF cause warning: CachedKafkaConsumer is not running in UninterruptibleThread (KAFKA-1894)

Use Kafka Streams for windowing data and processing each window at once

Why does kafka streams threads die when the source topic partitions changes ? Can anyone point to reading material around this?

What, exactly happens when a repartition occurs in a kafka stream?

Apache Kafka for Time Series Data Persistence

apache-kafka

Can single Kafka producer produce messages to multiple topics and how?

Spring Kafka JsonSerializer usage

How to get back Kafka producer and consumer configuration (Java API)?

How to authenticate/authorize a consumer in Kafka for a topic before it consumes the message

Kafka: Are there are examples on how to use Mockito for unit testing Kafka?

Kafka Consumer error: Marking coordinator dead

apache-kafka

Is there a way to dynamically stop Spark Structured Streaming?

How to efficiently create Kafka topics with testcontainers?

How does (should) Kafka Consumer cope with Poison Messages