QMQ是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景； 也包括报价搜索等高吞吐量场景。

A community-developed, free, opensource, automated testing framework for microservices APIs, Kafka(Data Streams) and Load testing. Zerocode Open Source enables you to create, change and maintain your automated test scenarios via simple JSON or YAML files. Visit documentation below:

RedisQ - Java implementation of a reliable Pub/Sub message queue based on Redis

Kafka streaming with Spark and Flink example

The purpose of this module is to solve the problem of multiple keystores using Spring Boot + Kafka + Schema Registry + SSL and Spring Schema Resgistry Test

The most simple way to test Kafka based applications or micro-services e.g. Read/Write during HBase/Hadoop or other Data Ingestion Pipe Lines

Robust SNS Client Producer. The Amazon SNS Java Messaging Library holds the compatible classes, that are used for communicating with Amazon Simple Notification Service.

基于Disruptor的异步任务执行框架。支持本地异步任务场景的快速开发。同时确保任务100%执行成功。

Java solution for producer and consumer problem

This repository contains code demonstrating the integration of Spring Cloud services with Apache Kafka for building scalable and resilient applications with event-driven architecture.

https://boottechnologies-ci.medium.com/apache-pulsar-consumer-and-producer-with-spring-boot-916fd06f669

Spring Boot Apache Kafka project integration with Github

Apache Kafka is an open-source stream-processing software platform developed by LinkedIn and donated to the Apache Software Foundation, written in Scala and Java. The project aims to provide a unified, high-throughput, low-latency platform for handling real-time data feeds, Kafka works well as a replacement for a more traditional message broker.

Apache Spark and Apache Kafka integration and Spark Analytics over DataFrame.

Credit Card Transaction Parser - Full stack parser project with reactjs and spring boot 3. This projects parse the credit-card transactions and kafka is used to produce and consume the parse data.

Alura Online Courses

Example of adding a message to the Kafka queue using Spring

Simple solution to producer - consumer problem.

Provides instrumenation of the Amazon Kinesis Client and Producer

Setup a Apache Kafka on Linux using JAVA (Gradle). Setting up producers to produce data into Kafka from wikimedia and then setting up consumers and pulling data into Open Search.