Kafka enjoys solid framework support, including in Spring. If you've reached this far in the workshop and want to try your hand at some more complex Kafka usage, a basic Spring Boot application has been set up for you to extend and experiment with.
- The application uses simple string messages. Create a schema and implement a producer using this schema. Then, implement a
@KafkaListenerusing this schema to populate a local in-memory state storage with what you receive from Kafka - Try parallelizing without starting separate applications, using the
@KafkaListenerconcurrency parameter - Using a console producer, try writing a non-Avro message to your topic from step 1. What happens? Try implementing a
@KafkaListenerwith@RetryableTopic-handling. - Try writing another application, and trigger changes in one application by sending messages from the first.