Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Kafka Streams – best way to get KTable and KStream on same topic?

In a publish/subscribe model in microservices, how to receive/consume a message only once per service type

Kafka Streams - Processor context commit

Can talk to Zookeeper but not to the message brokers

how to load a Kafka topic to HDFS?

hadoop apache-kafka

apache- kafka with 100 millions of topics

How to find which consumer is assigned to which partition of a topic in kafka?

Kafka streams - joining two ktables invokes join function twice

KTable state store infinite retention

Kafka Streams: Custom TimestampExtractor for aggregation

Share storage/volume between worker nodes in Kubernetes?

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