kafka

Trench — 开源分析基础设施。一个基于 ClickHouse、Kafka 和 Node.js 构建的单一生产级 Docker 镜像，用于跟踪事件。轻松构建产品分析仪表板、LLM RAG、可观测性平台或任何其他分析产品。

用于 Kafka 的 Python 流式 DataFrames

支持 Confluent 演示、演讲与博客的脚本和示例。此仓库中的部分示例未保持最新状态。如需自动化教程与经过质量保证的代码，请参阅 https://github.com/confluentinc/tutorials/

Harkirat Singh 的 100xDevs Cohort 3 🚀。此存储库包含课程代码、笔记、作业、作业解答代码以及一些优质文章/博客链接。🔥

使用短暂的 Docker 容器测试代码，无需编写 Mock 📦 只需几行代码即可设置热门服务 ⏱️ 没有 bash，没有 yaml，只有代码 💻

可靠消息解决分布式事务

分布式 Prometheus 时序数据库

适用于 Apache Kafka 的 Rust 客户端

OLake - 最快的数据库、Kafka 与 S3 复制工具，支持 Apache Iceberg 与表格优化（称为 OLake Fusion）。⚡ 针对实时分析提供高效、快速且具可扩展性的数据导入。支持的来源：Postgres, MongoDB, MySQL, Oracle, MSSql, DB2, Kafka, S3。

Alpakka Kafka 连接器 - Alpakka 是一个基于 Reactive Streams 与 Akka 的 Java 和 Scala 反应式企业集成库。

Kafka 的 asyncio 客户端

高性能 mqtt broker

适用于 Docker 与 Kubernetes 的 50+ 个 DockerHub 公开镜像 - DevOps、CI/CD、GitHub Actions、CircleCI、Jenkins、TeamCity、Alpine、CentOS、Debian、Fedora、Ubuntu、Hadoop、Kafka、ZooKeeper、HBase、Cassandra、Solr、SolrCloud、Presto、Apache Drill、Nifi、Spark、Consul、Riak

Wait4X 让你能够等待端口或服务进入请求的状态。

java-study 是本人学习 Java 过程中记录的一些代码！从 Java 基础的数据类型、jdk1.8 的 Lambda、Stream 和日期的使用、IO 流、数据集合、多线程使用、并发编程、23 种设计模式示例代码、常用的工具类，以及一些常用框架，netty、mina、springboot、kafka、storm、zookeeper、redis、elasticsearch、hbase、hive等等。

Kafka-King 是一款现代化、实用的 Kafka GUI 客户端，旨在通过直观的桌面界面简化 Apache Kafka 管理。作为一款跨平台应用程序，它为开发人员和管理员提供了强大的工具，可与 Kafka 集群交互，无需依赖命令行界面或基于 Web 的解决方案。

高性能的 Rust 流处理引擎，无缝集成 AI 功能，提供强大的实时数据处理与智能分析。

用于 Apache Kafka 的 Ruby 客户端库

pmacct 是一套小型多功能被动网络监控工具 [NetFlow IPFIX sFlow libpcap BGP BMP RPKI IGP Streaming Telemetry]。

go-stash 是一个高性能、免费且开源的服务器端数据处理管道，能从 Kafka 接收数据、进行处理，然后传送到 ElasticSearch。

imi 是一款支持长连接微服务分布式的 PHP 开发框架，它可以运行在 PHP-FPM、Swoole、Workerman、RoadRunner 等多种容器环境下。它支持 HttpApi、WebSocket、TCP、UDP、MQTT 服务的开发。特别适合互联网微服务、即时通讯聊天im、物联网等场景！QQ群：17916227

KCenter (KafkaCenter) 是一个用于 kafka 集群管理与维护、生产者/消费者监控，以及生态组件（ksql/kafka connect）使用的统一平台。

适用于 cp-all-in-one、cp-all-in-one-community、cp-all-in-one-cloud、Apache Kafka Confluent Platform 的 docker-compose.yml 文件

企业级网络流量收集器 (IPFIX, sFlow, Netflow)

450+ AWS、Hadoop、Cloud、Kafka、Docker、Elasticsearch、RabbitMQ、Redis、HBase、Solr、Cassandra、ZooKeeper、HDFS、Yarn、Hive、Presto、Drill、Impala、Consul、Spark、Jenkins、Travis CI、Git、MySQL、Linux、DNS、Whois、SSL 证书、Yum 安全更新、Kubernetes、Cloudera 等...

使用 golang 模仿的 Logstash。用于消费 Kafka 数据，处理后写入 ES、Clickhouse 等。

🔥 🔥 官方推荐 🔥 🔥 高并发大麦网售票系统，使用 SpringCloud、Kafka、Redis、Sentinel、ElasticSearch、ShardingSphere 等，通过优化锁的策略、多级缓存管理、数据提前预热、精确的定制限流等多种策略，显著降低下单延迟。此外还解决各种高并发难题的实际落地解决方案。是面试、就业、提高技术的不二选择！

由 Lenses.io 维护的 Kafka Connect 接收器与来源集合

用于管理 Apache Kafka 的命令行工具

🎉🎉🎉JAVA高级架构师技术栈==任何技能通过 “刻意练习” 都可以达到融会贯通的境界，就像烹饪一样，这里有一份JAVA开发技术手册，只需要增加自己练习的次数。🏃🏃🏃