Spring Boot Microservices Tutorial Part 11 - Integrating Kafka with Schema Registry

In this Spring Boot 3 Microservices tutorial series, we will learn how to build microservices using Spring Boot and Spring Cloud.

This is part 11 of the series, in this part, we will cover:
- Setting up Kafka, Schema Registry, and Kafka UI using Docker Compose
- Implement Producer and Consumer using Kafka
- Implement Schema Registry

[ShivamKumar-emnr]

While adding avro-maven-plugin i faced some issue. So added version of it and it worked.
Just below add the version
<version>1.11.0</version>

[konstantingromov]

Great tutorial, thank you man.
I actually never heard before about this project - schema registry which seems to very useful - to follow DRY and what is more important avoid some adapters for different programming languages (I assume it's not available for java, right?).
One small question - doesn't it make sense to use schema-registry as a separate module (aka lib) and add as a dependency for order-service and notification-service?

[mateuslevi]

I understand that one of the key concepts of microservices is the independence between services. My question is: does having, for example, a call to the inventory service (check inventory) in order service contradict this principle? Great job. learning a lot

[AkshatMehra-lb]

Great to see the email service being added here :)

[progperspectives]

I liked the tutorial. It's very good!

[hemalathabalachandar]

Great one. can you please create video on schema registry with json instead of avro.

[Andreas-vimo]

Ser, can i ask ur whole spring microservice project code? Because i got a problem at "Order Product Feature". When i try to add product, it works well. But, when i try to order product, it doesn't work.

[konstantingromov]

@ProgrammingTechie can you please update links to repository and blog (blog follows to Spring Boot Microservices Tutorial – Part 7)

[KeshavSingh-rd]

can u create one video for database replication like in mysql we have master slave architecture

[tasos]

can i use kafka opperation for communication between the services instead of rest clients? In case of the inventory rest client we used in order-service, could have a kafka producer also a kafka consumer when the producer is sending the order to inventory and inventory consume the order and response with a kafka producer so the consumer of order service consuming the inventory response instead of use rest clients or it isnt recommended?

[thebaseofpcmbfondation]

pls can you launch a online courses for microservices

[techlead_ashu]

What's the point of using schema registry like this?
It said it would centralize schema defn, creation, etc.
But here, you copied and pasted avro schema files from producer to consumer, just like earlier you had copy pasted event package with it's corresponding class!

You said things like single source of truth, but here also there are 2 avro schemas.
Can you help me understand if i'm missing something?

My 2 biggest concerns/queries are:
1. If say the team working on order service change avro schema and it isn't communicated to notifications team, then again code will break. The problem with 2 sources of truth that was present when u just copied the event package and it's class is still present inspite of using schema registry.

2. Why did you publish it to a URL from producer? i expected you to use that URL in consumer to get schema from URL and generate class in consumer. Is this intuitive educated guess of mine correct or not?

[faizanhaidar]

Brilliant work, But I could not find integration test.

[alexrv]

not working, all time error - Error deserializing key/value for partition order-create-0 at offset 5. If needed, please seek past the record to continue consumption. Whatever I do. I watched course just for this lesson, very bad(((