apache-kafka tutorials and guides

How to send and consume json messages using confluent-kafka in Python

Aug 17, 2022

No JAAS configuration section named 'Server' was foundin '/kafka/kafka_2.12-2.3.0/config/zookeeper_jaas.conf'

Aug 22, 2020

apache-kafka apache-zookeeper jaas apache-kafka-security

Kafka stream: "TopicAuthorizationException: Not authorized to access topics" for an internal state store

May 21, 2022

apache-kafka apache-kafka-streams

How can I disable spring cloud stream for development purpose when there are not kafka broker running?

Oct 30, 2022

java spring apache-kafka spring-cloud spring-cloud-stream

Filter the records by a certain value in kafka connect

Nov 10, 2022

json sql-server apache-kafka apache-kafka-connect debezium

Kafka Serialization of an object [duplicate]

Mar 06, 2022

serialization apache-kafka

Best practice for integrating Kafka and HBase

Sep 05, 2022

apache-spark hbase apache-kafka apache-storm flume

Kafka check queue size

Jun 08, 2022

python apache-kafka message-queue distributed

how to fetch a field in ConsumerRecord

Oct 20, 2019

python apache-kafka namedtuple

Kafka Stream from JSON to Avro

Feb 05, 2020

json apache-kafka avro apache-kafka-streams

Not able to connect to wurstmeister/kafka

Sep 15, 2022

docker apache-kafka docker-compose

spark streaming assertion failed: Failed to get records for spark-executor-a-group a-topic 7 244723248 after polling for 4096

Mar 17, 2022

apache-spark apache-kafka spark-streaming

For AvroProducer to Kafka, where are avro schema for "key" and "value"?

Nov 08, 2022

apache-kafka kafka-producer-api kafka-python

Event Sourcing: concurrently creating conflicting events

Oct 22, 2022

concurrency apache-kafka event-sourcing

How to convert bytes from Kafka to their original object?

Nov 07, 2021

apache-spark apache-kafka spark-streaming spark-avro

Java Kafka consumer group failing to consume a few messages

Nov 14, 2020

java apache-kafka

Using Spark Structured Streaming to Read Data From Kafka, Issue of Over-time is Always Occured

Apr 19, 2021

apache-spark apache-kafka spark-structured-streaming

Messaging platform with QoS / Kafka partition overloading

Sep 05, 2022

apache-kafka messaging

How to get windowed aggregation from kafka stream?

Mar 29, 2022

java apache-kafka apache-kafka-streams

How to use maxOffsetsPerTrigger in pyspark structured streaming?

Aug 25, 2022

pyspark apache-kafka

New posts in apache-kafka