I just published a new video where I take you behind the scenes of building a real-time event processing application using Spring Boot and Kafka Streams.
๐ ๏ธ In this video, I cover:
โ Designing a clean, modular Kafka Streams topology
โ Using Serde for JSON serialization of domain objects
โ Extracting logic into a service layer and helper classes
โ Keeping configuration and business logic separate
โ Writing unit tests with JUnit 5 and Mockito
โ Fixing tricky test execution errors (NoSuchMethodError, missing artifacts)
โ Understanding when to use @Bean vs @Service for stream startup
๐งญ The app processes visit events across Lille city ๐๏ธ and routes them to different Kafka topics based on a timetable validation logic.
๐น Watch the full video here:
๐ https://youtu.be/s07d3SmoBMI
๐ If you're building streaming apps or exploring event-driven architecture with Spring, I think this will help you a lot.
Let me know what you thinkโand feel free to share with anyone working on real-time data systems! ๐
#KafkaStreams #SpringBoot #CleanArchitecture #EventDrivenArchitecture #RealTimeData #ApacheKafka #JavaDeveloper #JUnit5 #Mockito #SoftwareEngineering #DevCommunity #SpringDeveloper #Microservices #LinkedInLearning