Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

kafka producer unit test (java)

Can the same Zookeeper instance be used by number of services?

KeeperErrorCode = NoNode for /brokers/topics/test-topic/partitions

scala apache-kafka

apache spark streaming - kafka - reading older messages

Kafka client for PHP

php client 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