Kafka MockConsumer and MockProducer Example (JUnit 6)
Unit test Kafka producers and consumers with MockProducer and MockConsumer in JUnit 6. Send, read, simulate failures and fix the two setup traps.
Related Tags
Tutorials
Kafka Queues: Share Groups (KIP-932) with Spring Kafka
Kafka queues let many consumers in a share group read the same partition and acknowledge each record on its own. This guide compares share groups with consumer groups, lists the status in Kafka 4.x and the broker settings, and builds a Spring Kafka share consumer with acknowledge, release and reject.
Kafka with Schema Registry and Avro Serialization
Learn to integrate Kafka with Apache Avro and Schema Registry to manage the changes in Schema over time, and a demo to test this integration.
Spring Boot @KafkaListener and @KafkaHandler Example
Spring @KafkaListener and @KafkaHandler annotations provide convenient ways to consume and handle messages from Kafka topics.
Using Spring KafkaAdmin to Create New Topics Programmatically
Learn to configure KafkaAdmin with custom properties, and create new topics in the Kafka cluster using AdminClient.createTopics() with example.
Using KafkaTemplate with Spring Boot
Learn the basics of KafkaTemplate, configure KafkaTemplate with custom properties, and configure producer and consumer factories with examples.
Kafka Cluster Setup Using Docker Compose (KRaft, Kafka 4)
Run a single-node Kafka and a 3-node Kafka cluster with Docker Compose in KRaft mode on Kafka 4.3, then test replication, leader election and failover with real output.
Kafka Multiple Consumers: Consumer Groups and Partitions
Kafka consumers with the same group.id split the partitions of a topic, while each consumer group gets every message. Real runs with 1 to 4 consumers, rebalance logs, assignment strategies, the new KIP-848 protocol and Spring Boot @KafkaListener concurrency.
Spring Boot Kafka JsonSerializer Example
Learn to use Kafka JsonSerializer and JsonDeserializer classes to store and retrieve JSON from Kafka topics and return the Java model.
Spring Boot and Kafka using Docker Compose
Learn to configure the Kafka producer and consumer in a Spring Boot 3 application and test using KafkaTemplate and @KafkaListener.
Installing Apache Kafka on Windows
Learn to install Apache Kafka on Windows 10 and execute ‘start server‘ and ‘stop server‘ scripts related to Kafka and Zookeeper. We will also verify the Kafka installation by creating a topic, producing a few messages to it and then using a Kafka consumer to read the messages. 1. Prerequisites …
Apache Kafka Tutorial
This Apache Kafka tutorial is for absolute beginners and discusses the architecture, core components and other advanced concepts.