Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Sending Large CSV to Kafka using python Spark

Kafka pattern subscription. Rebalancing is not being triggered on new topic

Kafka Partitions Reassignment Performance Impact

Heroku CLI does not recognize kafka as a command

heroku apache-kafka

leader election in zookeeper and Kafka

Reset the JDBC Kafka Connector to start pulling rows from the beginning of time?

EmbeddedKafka how to check received messages in unit test

Log compaction to keep exactly one message per key

apache-kafka

Is it possible to create ksql table from ksql stream?

apache-kafka ksqldb

Kafka Streams Testing : java.util.NoSuchElementException: Uninitialized topic: "output_topic_name"

best option to put Nginx logs into Kafka?

nginx apache-kafka

How to check if a topic was consumed by a consumer in Kafka

apache-kafka

kafka-node start consume from last offset

how to get the group commit offset from kafka(0.10.x)

apache-kafka

Distributed Kafka Connect topic configuration

kafka streams session window retention duration

Why does co-partitioning of two Kstreams in kafka require same number of partitions for both the streams?

Kafka minimal (production) setup

apache-kafka

Streaming messages from one Kafka Cluster to another

kafka connect multiple topics in sink connector properties