Example microservices showing how to use Kafka and Kafka Streams with Spring Boot on the example of distributed transactions implementations with the SAGA pattern

Automated documentation for event-driven applications built with Spring Boot

Spring Boot Kafka Producer Example

OpenTracing Instrumentation for Apache Kafka Client

Experiment with Kafka, Debezium, and ksqlDB. research-service: Performs MySQL record manipulation. Source Connectors: Monitor MySQL changes, push messages to Kafka. Sink Connectors and kafka-research-consumer: Listen to Kafka, insert/update Elasticsearch. ksqlDB-Server: Listens to Kafka, performs joins, and pushes new messages to new Kafka topics.

A sample of non-blocking retries and dead letter topics (aka reliable reprocessing and dead letter queues) with Apache Kafka using Spring Boot and Spring Kafka.

Showcases how to build a small Event-sourced application using Spring Boot, Spring Kafka, Apache Avro and Apache Kafka

Spring Boot demo apps for testing Kafka transactions with other resources like database

Kafka Examples focusing on Producer, Consumer, KStreams, KTable, Global KTable using Spring, Kafka Cluster Setup & Monitoring. Implementing Event Sourcing and CQRS Design Pattern using Kafka

整理java技术要点，让java更简单，更容易上手。

Test Spring Kafka application (using Avro as a serialization mechanism) without the need for Confluent Schema Registry

Integration Test in spring boot with spring kafka Embedded Kafka Consumer Producer

The goal is to play with Spring Kafka. We've implemented 5 examples of producer and consumer services that exchanges messages through Kafka using different types of serialization and approaches.

Experiments with Kafka clients and Spring Kafka. Demo code and tutorials.

Tools for integration testing of Apache Kafka with SpringBoot applications

Encapsulation based on spring-kafka not only supports native configuration, but also adds multi data source configuration.

kafka-producer-consumer-with-spring-boot

Contributor9 티스토리 블로그 내에서 활용한 내용들을 담은 레포지토리입니다.

This springboot project demonstrates blocking and non-blocking error handling - retry, recovery and dlt using spring kafka for kafka consumer.