{"repo":"rogervinas/spring-cloud-stream-kafka-step-by-step","free":true,"listed":false,"github":"https://github.com/rogervinas/spring-cloud-stream-kafka-step-by-step","clone":"git clone https://github.com/rogervinas/spring-cloud-stream-kafka-step-by-step.git","description":"🍀 Spring Cloud Stream Kafka - step by step","language":"Kotlin","stars":15,"topics":["spring-cloud-stream","kafka","kotlin"],"license":null,"category":"data-pipelines","readme_excerpt":"Spring Cloud Stream & Kafka binder step by step Spring Cloud Stream is the solution provided by Spring to build applications connected to shared messaging systems. It offers an abstraction (the binding ) that works the same whatever underneath implementation we use (the binder ): Apache Kafka Rabbit MQ Kafka Streams Amazon Kinesis ... Let's try to set up a simple example step by step and see how it works! This demo has been created using this spring initializr configuration adding Kafka binder dependency spring-cloud-starter-stream-kafka . Step by step: Producer with functional programming model Consumer with functional programming model Extras Kafka Message Key Retries Dead Letter Queue Test this demo Run this demo See also: :octocat: Spring Cloud Stream & Kafka Confluent Avro Schema Registry :octocat: Spring Cloud Stream & Kafka Streams Binder first steps :octocat: Spring Cloud Stream Multibinder :octocat: Spring Cloud Stream & Kafka Streams Binder + Processor API You can browse older versions of this repo: Spring Boot 2.x with legacy annotations (deprecated since spring-cloud-stream:3.1) Spring Boot 2.x with functional programming model Producer with functional programming model Our final goal is to produce messages to a Kafka topic. From the point of view of the application we want an interface MyEventProducer to produce events to a generic messaging system. These events will be of type MyEvent , just containing a text field to make it simpler: Then we follow these steps:","default_branch":null,"files":null,"tree":[],"storefront":"/r/rogervinas","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/rogervinas/spring-cloud-stream-kafka-step-by-step/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}