Topic: kafka Goto Github

👇 Here are 11102 public repositories matching this topic...

2227324689 / gpmall
kafka,【咕泡学院实战项目】-基于SpringBoot+Dubbo构建的电商平台-微服务架构、商城、电商、微服务、高并发、kafka、Elasticsearch
User: 2227324689
Home Page: http://vip.istio.tech/
kafka dubbo springboot zookeeper nacos springcloud-alibaba sentinel elasticsearch canal elk

aalansehaiyang / technology-talk
kafka,【大厂面试专栏】一份Java程序员需要的技术指南，这里有面试题、系统架构、职场锦囊、主流中间件等，让你成为更牛的自己！
User: aalansehaiyang
Home Page: https://offercome.cn/
java spring springboot dubbo kafka git hbase mycat spark es6

alibaba / alink
kafka,Alink is the Machine Learning algorithm platform based on Flink, developed by the PAI team of Alibaba computing platform.
Organization: alibaba
machine-learning flink classification clustering regression graph-algorithms xgboost recommender recommender-system feature-engineering

apache / flink-cdc
kafka,Flink CDC is a streaming data integration tool
Organization: apache
Home Page: https://nightlies.apache.org/flink/flink-cdc-docs-stable
change-data-capture cdc batch data-integration data-pipeline distributed elt etl flink kafka mysql paimon postgresql real-time schema-evolution

apache / kafka
kafka,Mirror of Apache Kafka
Organization: apache
kafka scala

arroyosystems / arroyo
kafka,Distributed stream processing engine in Rust
Organization: arroyosystems
Home Page: https://arroyo.dev
data data-stream-processing dev-tools infrastructure kafka rust sql stream-processing stream-processing-engine

asyncapi / spec
kafka,The AsyncAPI specification allows you to create machine-readable definitions of your asynchronous APIs.
Organization: asyncapi
Home Page: https://www.asyncapi.com
asyncapi reactive specification websockets amqp mqtt stomp kafka hacktoberfest

build-trust / ockam
kafka,Orchestrate end-to-end encryption, cryptographic identities, mutual authentication, and authorization policies between distributed applications – at massive scale.
Organization: build-trust
Home Page: https://ockam.io
messaging authentication key-management identity trust kafka rust security end-to-end-encryption encrypted-connections

coderleixiaoshuai / java-eight-part
kafka,『Java八股文』Java面试套路，Java进阶学习，打破内卷拿大厂Offer，升职加薪！
User: coderleixiaoshuai
java juc kafka mysql redis spring

conduktor / kafka-stack-docker-compose
kafka,docker compose files to create a fully working kafka stack
Organization: conduktor
docker docker-compose kafka kafka-rest-proxy kafka-schema-registry kafka-topics-ui zookeeper

datatalksclub / data-engineering-zoomcamp
kafka,Free Data Engineering course!
Organization: datatalksclub
data-engineering kafka spark dbt docker prefect

debezium / debezium
kafka,Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
Organization: debezium
Home Page: https://debezium.io
change-data-capture kafka-connect apache-kafka debezium cdc database kafka kafka-producer event-streaming

didi / knowstreaming
kafka,一站式云原生实时流数据平台，通过0侵入、插件化构建企业级Kafka服务，极大降低操作、存储和管理实时流数据门槛
Organization: didi
Home Page: https://knowstreaming.com
kafka kafkamonitor kafkamanager logikm cluster-manager multi-cluster clustermanager multi-cluster-management knowstreaming

dotnetcore / cap
kafka,Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern
Organization: dotnetcore
Home Page: http://cap.dotnetcore.xyz
kafka rabbitmq distributed-transactions outbox-pattern eventbus microservices service-bus

dpkp / kafka-python
kafka,Python client for Apache Kafka
User: dpkp
Home Page: http://kafka-python.readthedocs.io/
kafka python

fanliang11 / surging
kafka,Surging is a micro-service engine that provides a lightweight, high-performance, modular RPC request pipeline. support Event-based Asynchronous Pattern and reactive programming ,The service engine supports http, TCP, WS,Grpc, Thrift,Mqtt, UDP, and DNS protocols. It uses ZooKeeper and Consul as a registry, and integrates it. Hash, random, polling, Fair Polling as a load balancing algorithm, built-in service governance to ensure reliable RPC communication, the engine contains Diagnostic, link tracking for protocol and middleware calls, and integration SkyWalking Distributed APM
User: fanliang11
apigateway apollo consul dns-server grpc json-serialization kafka kestrel log4net memorycache messagepack microservices nlog protobuffer rabbitmq redis skywalking surging swagger zookeeper

graylog2 / graylog2-server
kafka,Free and open log management
Organization: graylog2
Home Page: https://www.graylog.org
log-analysis log-collector log-viewer logging logging-server siem secure-logging security gelf syslog

heibaiying / bigdata-notes
kafka,大数据入门指南 :star:
User: heibaiying
azkaban big-data bigdata flume hadoop hbase hdfs hive kafka mapreduce phoenix scala spark sqoop storm yarn zookeeper

ibm / sarama
kafka,Sarama is a Go library for Apache Kafka.
Organization: ibm
go kafka kafka-client

influxdata / telegraf
kafka,Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
Organization: influxdata
Home Page: https://influxdata.com/telegraf
telegraf monitoring time-series metrics gnmi golang influxdb json kafka logs

kubeshark / kubeshark
kafka,The API traffic analyzer for Kubernetes providing real-time K8s protocol-level visibility, capturing and monitoring all traffic and payloads going in, out and across containers, pods, nodes and clusters. Inspired by Wireshark, purposely built for Kubernetes
Organization: kubeshark
Home Page: https://kubeshark.co
kubernetes microservices golang rest grpc amqp kafka redis go microservice microservices-application devops devops-tools sniffer observability wireshark cloud-native docker forensics incident-response

materializeinc / materialize
kafka,The data warehouse for operational workloads.
Organization: materializeinc
Home Page: https://materialize.com
rust database sql streaming kafka distributed-systems postgresql-dialect materialized-view stream-processing postgresql

mikaelemmmm / go-zero-looklook
kafka,🔥基于go-zero(go zero) 微服务全技术栈开发最佳实践项目。Develop best practice projects based on the full technology stack of go zero (go zero) microservices.
User: mikaelemmmm
Home Page: https://go-zero.dev
go-zero golang go-queue goctl gozero microservices asynq dtm modd go-stash

nytimes / gizmo
kafka,A Microservice Toolkit from The New York Times
Organization: nytimes
Home Page: https://open.nytimes.com/introducing-gizmo-aa7ea463b208
go http-server pubsub google-pubsub sns sqs kafka gizmo googlecloud

obsidiandynamics / kafdrop
kafka,Kafka Web UI
Organization: obsidiandynamics
consumer-group consumer-producer docker event-sourcing event-streaming kafka kafka-tools kafka-ui kafka-utils kubernetes pub-sub topic web-ui zookeeper

opengoofy / hippo4j
kafka,📌 异步线程池框架，支持线程池动态变更&监控&报警，无需修改代码轻松引入。Asynchronous thread pool framework, support Thread Pool Dynamic Change & monitoring & Alarm, no need to modify the code easily introduced.
Organization: opengoofy
Home Page: https://hippo4j.cn
java thread-pool dynamic monitor dynamic-threadpool resizable blocking-queue springboot rocketmq kafka

pathwaycom / pathway
kafka,Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Organization: pathwaycom
Home Page: https://pathway.com
batch-processing kafka pathway python streaming machine-learning-algorithms real-time data-analytics data-pipelines data-processing

pipelineai / pipeline
kafka,PipelineAI
Organization: pipelineai
Home Page: https://generativeaionaws.com
machine-learning artificial-intelligence tensorflow kubernetes cassandra spark kafka airflow docker redis neural-network gpu pipelineai tfx keras kubeflow pytorch scikit-learn

provectus / kafka-ui
kafka,Open-Source Web UI for Apache Kafka Management
Organization: provectus
apache-kafka big-data cluster-management event-streaming hacktoberfest kafka kafka-brokers kafka-client kafka-cluster kafka-connect kafka-manager kafka-producer kafka-streams kafka-ui opensource streaming-data streams web-ui

qunarcorp / qmq
kafka, QMQ是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景； 也包括报价搜索等高吞吐量场景。
Organization: qunarcorp
mq message event event-driven kafka message-driven message-queue message-bus event-bus xa

redpanda-data / connect
kafka,Fancy stream processing made operationally mundane
Organization: redpanda-data
Home Page: https://docs.redpanda.com/redpanda-connect/about/
message-queue stream-processing streaming-data message-bus logs stream-processor cqrs event-sourcing go golang

redpanda-data / console
kafka,Redpanda Console is a developer-friendly UI for managing your Kafka/Redpanda workloads. Console gives you a simple, interactive approach for gaining visibility into your topics, masking data, managing consumer groups, and exploring real-time data with time-travel debugging.
Organization: redpanda-data
Home Page: https://redpanda.com
apache-kafka dataops react typescript kafka-ui kafka-gui web-ui go kafka

redpanda-data / redpanda
kafka,Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Organization: redpanda-data
Home Page: https://redpanda.com
kafka cpp kubernetes go streaming redpanda containers realtime event-driven microservices

rfyiamcool / share_ppt
kafka,🚗 个人做过的技术分享... ( topic: 高性能架构, 中间件原理实践，云原生，Golang 等)
User: rfyiamcool
Home Page: https://xiaorui.cc
ppt python golang keynote etcd kafka kubernetes mysql

risingwavelabs / risingwave
kafka,SQL stream processing, analytics, and management. We decouple storage and compute to offer efficient joins, instant failover, dynamic scaling, speedy bootstrapping, and concurrent query serving.
Organization: risingwavelabs
Home Page: https://www.risingwave.com/slack
database stream-processing cloud-native sql distributed-database rust serverless postgresql real-time postgres

robinhood / faust
kafka,Python Stream Processing
Organization: robinhood
kafka-streams kafka python asyncio distributed-systems stream-processing

sanshengshui / netty-learning-example
kafka,:egg: Netty实践学习案例，见微知著！带着你的心，跟着教程。我相信你行欧。
User: sanshengshui
netty http protobuf mqtt fastjson zero-copy kafka rpc iot im

segmentio / kafka-go
kafka,Kafka library in Go
Organization: segmentio
consumer go golang golang-library golang-native kafka kafka-client producer segment

smartloli / efak
kafka,A easy and high-performance monitoring system, for comprehensive monitoring and management of kafka cluster.
User: smartloli
Home Page: https://www.kafka-eagle.org/
consumer-group kafka kafka-eagle kafka-sql ksql offsets zookeeper

sogou / workflow
kafka,C++ Parallel Computing and Asynchronous Networking Framework
Organization: sogou
tasking http redis mysql kafka consul dag

strimzi / strimzi-kafka-operator
kafka,Apache Kafka® running on Kubernetes
Organization: strimzi
Home Page: https://strimzi.io/
data-stream data-streaming data-streams docker enmasse hacktoberfest kafka kafka-connect kafka-streams kubernetes kubernetes-controller kubernetes-operator messaging openshift

tchiotludo / akhq
kafka,Kafka GUI for Apache Kafka to manage topics, topics data, consumers group, schema registry, connect and more...
User: tchiotludo
Home Page: https://akhq.io/
kafka gui java kafkahq kafka-ui kafka-utils kafka-tools

thingsboard / thingsboard
kafka,Open-source IoT Platform - Device management, data collection, processing and visualization.
Organization: thingsboard
Home Page: https://thingsboard.io
dashboard visualization iot iot-platform mqtt coap middleware netty websockets widgets

threedotslabs / watermill
kafka,Building event-driven applications the easy way in Go.
Organization: threedotslabs
Home Page: https://watermill.io
watermill event-driven event-sourcing sagas events stream-processing reactive go golang rabbitmq

travisjeffery / jocko
kafka,Kafka implemented in Golang with built-in coordination (No ZK dep, single binary install, Cloud Native)
User: travisjeffery
Home Page: https://twitter.com/travisjeffery
kafka distributed-systems queue messaging go streaming

tulios / kafkajs
kafka,A modern Apache Kafka client for node.js
User: tulios
Home Page: https://kafka.js.org
kafka kafka-client nodejs npm-package

wangzhiwubigdata / god-of-bigdata
kafka,专注大数据学习面试，大数据成神之路开启。Flink/Spark/Hadoop/Hbase/Hive...
User: wangzhiwubigdata
flink spark hadoop hdfs hive hbase kafka zookeeper bigdata flume azkaban

yahoo / cmak
kafka,CMAK is a tool for managing Apache Kafka clusters
Organization: yahoo
big-data cluster-management kafka scala

yudaocode / springboot-labs
kafka,一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024
Organization: yudaocode
spring-boot spring-cloud spring-cloud-alibaba dubbo rocketmq rabbitmq kafka activemq

zhisheng17 / flink-learning
kafka,flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
User: zhisheng17
Home Page: http://www.54tianzhisheng.cn/tags/Flink/
flink kafka elasticsearch spark redis mysql rocketmq hbase rabbitmq stream-processing streaming clickhouse loki influxdb opentsdb