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

A community-developed, free, opensource, automated testing framework for microservices APIs, Kafka(Data Streams), Databases 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:

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

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

Consumer Banking Application

Another app which used to monitor the progress of Kafka Producer and Consumer

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

封装常用的生产者-消费者模型

FQueue - Simple thread-safe queue consumer with time and size batching.

kiwi-kafka - A Kafka Web Interface

Consume an async api (with callback) from sync endpoint using vert.x

Dockerized Kafka consumer

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

Meine dispatcher says there's something wrong mit deine Kabel. Java 8 BlockingQueue Kafka Consumer with automatically maintained offset.

spring-kakfa 多线程消费代码提交

OAuth1.0 consumer library.

The spring-kafka-cloud-events library provides utility in order to use the CloudEvents spec in your project that uses Spring-Kafka.

Little library to handle Consumers by ids.