Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

kafka-python consumer not receiving messages

How to fix "AssertionError: Value must be bytes" error in Python2.7 with Apache Kafka

python apache-kafka

What is a simple, effective way to debug custom Kafka connectors?

Spring Kafka Producer not sending to Kafka 1.0.0 (Magic v1 does not support record headers)

Kafka Structured Streaming KafkaSourceProvider could not be instantiated

Is Kafka Stream StateStore global over all instances or just local?

Json file data into kafka topic

apache-kafka

How to decode/deserialize Avro with Python from Kafka

python apache-kafka avro

Apache Flink: java.lang.NoClassDefFoundError

How to automatically start Kafka upon system startup in Ubuntu?

ubuntu apache-kafka init.d

Topic can't be found when producing messages: UNKNOWN_TOPIC_OR_PARTITION

Gracefully restart a Reactive-Kafka Consumer Stream on failure

KAFKA broker throwing Wrong request type 18 and Wrong request type 16

how to efficiently move data from Kafka to an Impala table?

Spark streaming + Kafka vs Just Kafka

Connection management when using kafka producer in high traffic environment

kafka: Commit offsets failed with retriable exception. You should retry committing offsets

java apache-kafka

"The configuration foo.bar was supplied but isn't a known config"

Is Apache Kafka able to handle transactions?

Spring Integration Kafka Consumer Listener not Receiving messages