apache-kafka tutorials and guides

Kafka: Is our number of partitions insane?

May 15, 2022

apache-kafka

How to fix kafka.common.errors.TimeoutException: Expiring 1 record(s) xxx ms has passed since batch creation plus linger time

Aug 20, 2022

apache-kafka kafka-producer-api spring-kafka

What is the optimal way to read from multiple Kafka topics and write to different sinks using Spark Structured Streaming?

Aug 26, 2022

apache-spark pyspark apache-kafka spark-structured-streaming

kafka consumer in R

Oct 14, 2022

python r apache-kafka

Apache Kafka Consumer group and Simple Consumer

Oct 23, 2022

apache-kafka

multiprocessing in kafka-python

Nov 21, 2020

apache-kafka kafka-consumer-api kafka-python

Why not let consumers pull messages from followers?

Sep 10, 2022

apache-kafka

Check all the lags in Kafka

May 13, 2022

apache-kafka

Spring kafka consumer, seek offset at runtime?

Oct 31, 2022

apache-kafka kafka-consumer-api spring-kafka

What happens if I don't close the kafka producer

Sep 11, 2022

java apache-kafka kafka-producer-api

Kafka Stream count on time window not reporting zero values

Feb 19, 2019

java apache-kafka apache-kafka-streams

Structured streaming : watermark vs. exactly-once semantics

Sep 15, 2022

apache-spark apache-kafka spark-structured-streaming

Kafka producer send blocks indefinitely when kafka servers are down

Apr 29, 2022

apache-kafka kafka-producer-api

Properly Configuring Kafka Connect S3 Sink TimeBasedPartitioner

Nov 18, 2022

amazon-s3 apache-kafka apache-kafka-connect confluent-platform

Guidelines to handle Timeout exception for Kafka Producer?

Sep 23, 2022

java apache-kafka kafka-producer-api timeoutexception

how many consumer groups can a kafka topic handle?

Aug 26, 2022

apache-kafka kafka-consumer-api kafka-topic

using mqtt protocol with kafka as a message broker

Oct 20, 2022

architecture rabbitmq scalability apache-kafka mqtt

How can I initialize kafka ConsumerRecords<String,String> in kafka for testing

Sep 14, 2022

java mocking apache-kafka powermock kafka-consumer-api

ClassNotFoundException: org.apache.flink.streaming.api.checkpoint.CheckpointNotifier while consuming a kafka topic

Apr 08, 2022

apache-kafka apache-flink flink-streaming

How kafka balances partitions load?

Nov 06, 2022

java performance apache-kafka load-balancing partition

New posts in apache-kafka