kafka

Trench — Cơ sở hạ tầng phân tích mã nguồn mở. Một image Docker sẵn sàng cho môi trường production được xây dựng trên ClickHouse, Kafka và Node.js để theo dõi sự kiện. Dễ dàng xây dựng bảng điều khiển phân tích sản phẩm, LLM RAG, nền tảng quan sát, hoặc bất kỳ sản phẩm phân tích nào khác.

Python Streaming DataFrames cho Kafka

Các tập lệnh và mẫu hỗ trợ Bản demo, Bài nói chuyện và Blog của Confluent. Không phải tất cả các ví dụ trong kho lưu trữ này đều được cập nhật thường xuyên. Để xem các hướng dẫn tự động và mã được kiểm tra chất lượng, hãy truy cập https://github.com/confluentinc/tutorials/

100xDevs Cohort 3 🚀 bởi Harkirat Singh. Repository này chứa mã bài giảng, ghi chú, bài tập, mã lời giải bài tập và một số liên kết bài viết/blog hay. 🔥

Kiểm thử mã nguồn mà không cần viết mock bằng các container Docker tạm thời 📦 Cài đặt các dịch vụ phổ biến chỉ với vài dòng mã ⏱️ Không bash, không yaml, chỉ có mã nguồn 💻

Tin nhắn đáng tin cậy giải quyết các giao dịch phân tán

Cơ sở dữ liệu chuỗi thời gian Prometheus phân tán

Client Rust cho Apache Kafka

OLake - Công cụ replication Cơ sở dữ liệu, Kafka & S3 nhanh nhất sang Apache Iceberg với tính năng tối ưu hóa bảng (được gọi là OLake Fusion). ⚡ Thu nạp dữ liệu hiệu quả, nhanh chóng và có khả năng mở rộng cho phân tích thời gian thực. Các nguồn được hỗ trợ: Postgres, MongoDB, MySQL, Oracle, MSSql, DB2, Kafka, S3.

Alpakka Kafka connector - Alpakka là thư viện Tích hợp Doanh nghiệp Phản ứng (Reactive Enterprise Integration) cho Java và Scala, dựa trên Reactive Streams và Akka.

Client asyncio cho Kafka

MQTT broker hiệu năng cao.

Hơn 50 DockerHub image công khai cho Docker & Kubernetes - 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 cho phép bạn chờ đợi một cổng hoặc dịch vụ đạt đến trạng thái yêu cầu.

java-study là một số mã nguồn được ghi lại trong quá trình học tập Java của cá nhân tôi! Từ các kiểu dữ liệu cơ bản trong Java, Lambda, Stream của jdk1.8 và cách sử dụng ngày tháng, luồng IO, tập hợp dữ liệu, sử dụng đa luồng, lập trình đồng thời, mã nguồn ví dụ cho 23 mẫu thiết kế, các lớp tiện ích phổ biến, cũng như một số framework thường dùng như netty, mina, springboot, kafka, storm, zookeeper, redis, elasticsearch, hbase, hive, v.v.

Kafka-King là một Kafka GUI client hiện đại và thiết thực, được thiết kế để đơn giản hóa việc quản lý Apache trực quan thông qua giao diện desktop.

Công cụ xử lý luồng bằng Rust hiệu suất cao tích hợp liền mạch các tính năng AI, cung cấp khả năng xử lý dữ liệu thời gian thực mạnh mẽ và phân tích thông minh.

Thư viện Ruby client dành cho Apache Kafka

pmacct là một tập hợp nhỏ các công cụ giám sát mạng thụ động đa mục đích [NetFlow IPFIX sFlow libpcap BGP BMP RPKI IGP Streaming Telemetry].

go-stash là một đường ống xử lý dữ liệu phía máy chủ hiệu suất cao, miễn phí và mã nguồn mở, nhận dữ liệu từ Kafka, xử lý và sau đó gửi đến ElasticSearch.

imi là một framework phát triển PHP hỗ trợ kết nối lâu dài, phân tán vi dịch vụ, có thể chạy trong nhiều môi trường container như PHP-FPM, Swoole, Workerman, RoadRunner, v.v. Hỗ trợ phát triển dịch vụ HttpApi, WebSocket, TCP, UDP, MQTT. Đặc biệt phù hợp cho các kịch bản vi dịch vụ internet, trò chuyện IM thời gian thực, IoT, v.v.

KCenter (KafkaCenter) là một nền tảng thống nhất để quản lý và bảo trì cụm kafka, giám sát nhà sản xuất / người tiêu dùng, và sử dụng các thành phần sinh thái (ksql/kafka connect). Đây là kafkacenter (kafka center).

Các tệp docker-compose.yml cho cp-all-in-one, cp-all-in-one-community, cp-all-in-one-cloud và Apache Kafka Confluent Platform

Bộ thu thập lưu lượng mạng doanh nghiệp (IPFIX, sFlow, Netflow)

Hơn 450 công nghệ bao gồm 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, Chứng chỉ SSL, Cập nhật bảo mật Yum, Kubernetes, Cloudera, v.v...

Logstash được viết lại bằng Golang. Dùng để tiêu thụ dữ liệu từ Kafka, xử lý rồi ghi vào ES, Clickhouse, v.v.

Hệ thống bán vé Damai hiệu năng cao, sử dụng SpringCloud, Kafka, Redis, Sentinel, ElasticSearch, ShardingSphere, v.v., giảm đáng kể độ trễ đặt hàng thông qua việc tối ưu hóa chiến lược khóa, quản lý bộ nhớ đệm nhiều cấp, làm ấm trước dữ liệu, giới hạn tốc độ tùy chỉnh chính xác và nhiều chiến lược khác. Ngoài ra, nó giải quyết các vấn đề thực tế về xử lý đồng thời cao. Đây là lựa chọn hàng đầu cho phỏng vấn, việc làm và nâng cao kỹ năng!

Bộ sưu tập các Kafka Connect sink và source được duy trì bởi Lenses.io.

Công cụ dòng lệnh để quản lý Apache Kafka

🎉🎉🎉 Ngăn xếp công nghệ kiến trúc sư Java cao cấp == Bất kỳ kỹ năng nào cũng có thể đạt đến độ uyển chuyển thông qua luyện tập có chủ đích, giống như nấu ăn, đây là sổ tay kỹ thuật phát triển Java, bạn chỉ cần tăng số lần luyện tập của mình. 🏃🏃🏃