Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How can Kafka limitations be avoided? [closed]

Error reading field 'topic_metadata' in Kafka

Spark DStream periodically call saveAsObjectFile using transform does not work as expected

Kafka - stop retrying on ConnectException

java apache-kafka

kafka-node LeaderNotAvailable errors on send

Guaranteed delivery of multiple messages to Kafka cluster

kafka log-compaction consuming data

java apache-kafka

Is there any way to use confluent schema registry with kafka-node module?

How to check if Kafka Consumer is ready

apache-kafka rebalancing

kafka ack=all and min-isr

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?