meitu / Go Consumergroup
Licence: mit
golang kafka consumer group
Stars: ✭ 67
Labels
Projects that are alternatives of or similar to Go Consumergroup
Springwolf Core
Automated documentation for async APIs built with Spring Boot
Stars: ✭ 63 (-5.97%)
Mutual labels: kafka
Ssm
销售系统项目，spring+spring mvc+mybatis+dubbo+kafka+redis+maven
Stars: ✭ 55 (-17.91%)
Mutual labels: kafka
Kryptoflow
Real-time analysis of bitcoin markets with Kafka and Tensorflow Serving
Stars: ✭ 66 (-1.49%)
Mutual labels: kafka
Spring Cloud Stream Demo
Simple Event Driven Microservices with Spring Cloud Stream
Stars: ✭ 58 (-13.43%)
Mutual labels: kafka
Camel Kafka Connector
Camel Kafka Connector allows you to use all Camel components as Kafka Connect connectors
Stars: ✭ 63 (-5.97%)
Mutual labels: kafka
Model Serving Tutorial
Code and presentation for Strata Model Serving tutorial
Stars: ✭ 57 (-14.93%)
Mutual labels: kafka
Ansible Playbook
Ansible playbook to deploy distributed technologies
Stars: ✭ 61 (-8.96%)
Mutual labels: kafka
Pykafka
Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.
Stars: ✭ 1,079 (+1510.45%)
Mutual labels: kafka
Ksql Fork With Deep Learning Function
Deep Learning UDF for KSQL, the Streaming SQL Engine for Apache Kafka with Elasticsearch Sink Example
Stars: ✭ 64 (-4.48%)
Mutual labels: kafka
Pretendyourexyzzy
A web clone of the card game Cards Against Humanity.
Stars: ✭ 1,069 (+1495.52%)
Mutual labels: kafka
Karamel
Kafka Browser that supports standalone Kafka and Strimzi operator
Stars: ✭ 61 (-8.96%)
Mutual labels: kafka
Thingsboard
Open-source IoT Platform - Device management, data collection, processing and visualization.
Stars: ✭ 10,526 (+15610.45%)
Mutual labels: kafka
go-consumergroup 
Go-consumergroup is a kafka consumer library written in golang with rebalance and chroot supports.
Requirements
- Apache Kafka 0.8.x, 0.9.x, 0.10.x
Dependencies
Getting started
- API documentation and examples are available via godoc.
- The example directory contains more elaborate example applications.
User Defined Logger
logger := logrus.New()
cg.SetLogger(logger)
Run Tests
$ make test
NOTE: docker-compse is required to run tests
Note that the project description data, including the texts, logos, images, and/or trademarks,
for each open source project belongs to its rightful owner.
If you wish to add or remove any projects, please contact us at [email protected].