Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to send final kafka-streams aggregation result of a time windowed KTable?

What is the difference between kafka earliest and latest offset values

How to programmatically create a topic in Apache Kafka using Python

Why do Kafka consumers connect to zookeeper, and producers get metadata from brokers?

How to change start offset for topic?

apache-kafka offset

Consumer not receiving messages, kafka console, new consumer api, Kafka 0.9

How to install Kafka on Windows?

windows apache-kafka

Simple embedded Kafka test example with spring boot

What is the difference between MQTT broker and Apache Kafka

apache-kafka mqtt iot

zookeeper is not a recognized option when executing kafka-console-consumer.sh

Kafka Consumer get key value pair

When does the Apache Kafka client throw a "Batch Expired" exception?

How to write a file to Kafka Producer

How to create a Topic in Kafka through Java

classpath is empty. please build the project first

Why could Kafka warn "partitions have leader brokers without a matching listener"?

How to see the retention for a particular topic in kafka

apache-kafka retention

Which directory does apache kafka store the data in broker nodes

apache-kafka

Handling bad messages using Kafka's Streams API

Topics, partitions and keys