Our great sponsors
-
WorkOS
The modern identity platform for B2B SaaS. The APIs are flexible and easy-to-use, supporting authentication, user identity, and complex enterprise features like SSO and SCIM provisioning.
I've created this spring-cloud-stream-step-by-step demo to see how it works!
Remember that everything under spring.cloud.kafka.binder is related to the Kafka binder implementation and we can use all these extra Kafka binder properties and everything under spring.cloud.stream.bindings is related to the Spring Cloud Stream binding abstraction and we can use all these extra binding properties.
MyStreamEventConsumer has a method consume annotated with @StreamListener linking it to the my-consumer binding. This means that every time a new message is received in the Kafka topic, its payload will be deserialized to a MyEventPayload (applying Jackson annotations) and the consume method will we called.