Topic: kafka Goto Github

👇 Here are 11320 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

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 dev-tools infrastructure kafka rust sql stream-processing data-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

automq / automq
kafka,AutoMQ is a cloud-first alternative to Kafka by decoupling durability to S3 and EBS. 10x cost-effective. Autoscale in seconds. Single-digit ms latency.
Organization: automq
Home Page: https://www.automq.com/docs
cloud-native kafka messaging s3 storage streaming cloud cloud-economics ebs minio serverless spot aws azure gcp

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
authentication authorization credentials distributed-systems e2ee encrypted-connections encrypted-messages encryption end-to-end-encryption identity kafka key-management messaging rust security snowflake trust zero-trust

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

conduktor / kafka-stack-docker-compose
kafka,docker compose files to create a fully working kafka stack
Organization: conduktor
docker-compose docker kafka-schema-registry kafka kafka-topics-ui kafka-rest-proxy 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
hadoop hdfs yarn mapreduce hive spark storm hbase scala kafka

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

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 modbus mqtt opcua windows-eventlog windows-management-instrumentation xpath

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

materializeinc / materialize
kafka,The Cloud Operational Data Store: use SQL to transform, deliver, and act on fast-changing data.
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
kafka kubernetes docker consumer-group consumer-producer pub-sub event-sourcing event-streaming kafka-ui kafka-utils

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

provectus / kafka-ui
kafka,Open-Source Web UI for Apache Kafka Management
Organization: provectus
kafka-ui kafka-brokers kafka kafka-streams kafka-client opensource kafka-connect kafka-producer streams big-data

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

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 go kafka kafka-gui kafka-ui react typescript web-ui

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 storage-engine stream-processing seastar

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 for event-driven workloads. Perform streaming analytics, or build event-driven applications, real-time ETL pipelines, and feature stores in minutes. Unified streaming and batch processing. PostgreSQL compatible.
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
asyncio distributed-systems kafka kafka-streams python 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
kafka golang go segment kafka-client consumer producer golang-library golang-native

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/
kafka kafka-eagle kafka-sql offsets consumer-group zookeeper ksql

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

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

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
cqrs event-driven event-sourcing events go golang kafka nats rabbitmq reactive sagas stream-processing watermill

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

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/
clickhouse elasticsearch flink hbase influxdb kafka loki mysql opentsdb rabbitmq redis rocketmq spark stream-processing streaming