Spring Kafka

Index

1. Resources
   • v3.1 features
2. Producer
3. Consumer
   • consumer variations -8
   • consumer factory
4. Todo
5. Findings/Answers

---

API Docs:

1. https://docs.spring.io/spring-kafka/docs/current/api/

For new features added in specific version of spring-kafka refer :

1. https://docs.spring.io/spring-kafka/docs/ [refer the version from below link if not knoe–>select version > refernces>htmls]
2. https://spring.io/projects/spring-kafka#learn

Notes to implement for performance:

https://spring.io/projects/spring-kafka#learn

linkedln :

13 ways to learn Kafka:

1. 1. Tutorial: Official Apache Kafka Quickstart – https://lnkd.in/eVrMwgCw
2. 2. Documentation: Official Apache Kafka Documentation – https://lnkd.in/eEU2sZvq
3. 3. Tutorial: Kafka Learning with RedHat – https://lnkd.in/em-wsvDt
4. 4. Read: Kafka – The Definitive Guide: Real-Time Data and Stream Processing at Scale – https://lnkd.in/ez3aCVsH
5. 5. Course: Apache Kafka Essential Training: Getting Started – https://lnkd.in/ettejx2w
6. 6. Read: Kafka in Action – https://lnkd.in/ed7ViYQZ
7. 7. Course: Apache Kafka Deep Dive – https://lnkd.in/ekaB9mv6
8. 8. Read: Apache Kafka Quick Start Guide – https://lnkd.in/e-3pSXnu
9. 9. Course: Learn Apache Kafka for Beginners – https://lnkd.in/ewh6uUyT
10. 10. Course: Apache Kafka Crash Course for Java and Python Developers – https://lnkd.in/e72AHUY4
11. 11. Read: Mastering Kafka Streams and ksqlDB: Building real-time data systems by example – https://lnkd.in/eqr_DaY2
12. 12. Course: Deploying and Running Apache Kafka on Kubernetes – https://lnkd.in/ezQ58usN
13. 13. Course: Stream Processing Design Patterns with Kafka Streams – https://lnkd.in/egrks3rn

---

Kafka 3.1 features –

1. Micrometer observations –
   • https://docs.spring.io/spring-kafka/docs/current/reference/html/#observation
2. Same broker for multiple test cases
3. Retryable topic changes are permanent.
4. KafkaTemplate supporting CompletableFuture(?) instead of LIstenableFuture(?).
5. Testing Changes
   • Since 3.0.1 the application sets the default broker to application broker spring.kafka.bootstrap-servers – default embedded one.
   • .

References: https://docs.spring.io/spring-kafka/docs/current/reference/html/

Points :

1. Starting with version 2.5 , Broker can be changed at runtime – Section “Connecting to Kafka”
   • Suport For ABSwitchCluster -one cluster active at a time

---