Spring Kafka Integration

Kafka & MessagingTopic 9 of 152 questions

Q1How do you test Spring Kafka: embedded broker integration tests and mocking KafkaTemplate in unit tests?

Mock KafkaTemplate for fast unit tests of your logic, and use an embedded broker or Testcontainers for integration tests that prove a producer and consumer really work end to end.

Read Answer

Q2What does Spring Kafka add over the raw client, and how does the listener container `concurrency` map threads to partitions?

Spring Kafka hides the poll loop and commit plumbing; KafkaTemplate is the thread-safe sender and concurrency gives you one consumer thread per partition up to the partition count.

Read Answer