Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to enable Kafka logging with log4j

java log4j apache-kafka slf4j

Conditions in which Kafka Consumer (Group) triggers a rebalance

How to always consume from latest offset in kafka-streams

_pickle.PicklingError: Could not serialize object: TypeError: can't pickle _thread.RLock objects

Apache Kafka the order of messages in partition guarantee

How to list all producers of a kafka cluster?

Apache Kafka: Failed to Update Metadata/java.nio.channels.ClosedChannelException

Stop a Kafka Streams app

Kafka KStreams - processing timeouts

Spring-Boot logging to Kafka: how to eliminate warning; best practices

Why consumer hangs while consuming messages from Kafka on DC/OS using Client API for Java?

java apache-kafka dcos

IllegalArgumentException: /tmp/zookeeper/myid file is missing

Zookeeper on same node as kafka?

Kafka Consumer seektoBeginning

Limit kafka batch size when using Spark Structured Streaming

Kafka: What is the minimum number of brokers required for high availability?

How to output result of windowed aggregation only when window is finished? [duplicate]

Spring boot Kafka class deserialization - not in the trusted package

Apache Kafka: consumer state

How to stop Python Kafka Consumer in program?