apache-kafka tutorials and guides

Can single Kafka producer produce messages to multiple topics and how?

Nov 03, 2022

apache-kafka kafka-producer-api

Spring Kafka JsonSerializer usage

Oct 16, 2022

java spring serialization apache-kafka spring-kafka

How to get back Kafka producer and consumer configuration (Java API)?

Oct 16, 2022

java api apache-kafka kafka-consumer-api kafka-producer-api

How to authenticate/authorize a consumer in Kafka for a topic before it consumes the message

Nov 07, 2022

apache-kafka kafka-consumer-api

Kafka: Are there are examples on how to use Mockito for unit testing Kafka?

Feb 21, 2022

unit-testing apache-kafka mockito

Kafka Consumer error: Marking coordinator dead

Oct 21, 2022

apache-kafka

Is there a way to dynamically stop Spark Structured Streaming?

Oct 29, 2022

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

How to efficiently create Kafka topics with testcontainers?

Jun 05, 2022

apache-kafka testcontainers

How does (should) Kafka Consumer cope with Poison Messages

Oct 29, 2022

apache-kafka kafka-consumer-api

Kafka Streams – best way to get KTable and KStream on same topic?

Nov 06, 2022

apache-kafka apache-kafka-streams

In a publish/subscribe model in microservices, how to receive/consume a message only once per service type

Sep 07, 2022

rabbitmq apache-kafka messaging publish-subscribe microservices

Kafka Streams - Processor context commit

May 10, 2021

apache-kafka apache-kafka-streams

Can talk to Zookeeper but not to the message brokers

Sep 13, 2022

python amazon-web-services apache-kafka kafka-producer-api amazon-msk

how to load a Kafka topic to HDFS?

Feb 09, 2022

hadoop apache-kafka

apache- kafka with 100 millions of topics

Nov 08, 2022

apache-kafka kafka-consumer-api kafka-producer-api

How to find which consumer is assigned to which partition of a topic in kafka?

May 19, 2019

java apache-kafka kafka-consumer-api apache-zookeeper

Kafka streams - joining two ktables invokes join function twice

Nov 15, 2022

apache-kafka apache-kafka-streams

KTable state store infinite retention

Dec 05, 2019

apache-kafka apache-kafka-streams

Kafka Streams: Custom TimestampExtractor for aggregation

Nov 12, 2022

apache-kafka apache-kafka-streams

Share storage/volume between worker nodes in Kubernetes?

Sep 17, 2021

docker kubernetes apache-kafka kubernetes-pod

New posts in apache-kafka