502 Open source projects that are alternatives of or similar to Rust Rdkafka

Bitnami Docker Image for Kafka

WaterDrop is a standalone Karafka component library for generating Kafka messages

Manage your topic's configuration (partitions, replication factor, parameters), ACLs, quotas, and get stats, without any effort with this library. It does not use the Kafka scripts and does not require ssh connection to the remote broker.

Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.

Python client for Apache Kafka

🦄 开源社区系统：基于 SpringBoot + MyBatis + MySQL + Redis + Kafka + Elasticsearch + Spring Security + ... 并提供详细的开发文档和配套教程。包含帖子、评论、私信、系统通知、点赞、关注、搜索、用户设置、数据统计等模块。

Asynchronous Web framework for Rust

Samsara is a real-time analytics platform

Wirbelsturm is a Vagrant and Puppet based tool to perform 1-click local and remote deployments, with a focus on big data tech like Kafka.

National Stock Exchange (NSE), India based Stock screener program. Supports Live Data, Swing / Momentum Trading, Intraday Trading, Connect to online brokers as Zerodha Kite, Risk Management, Emotion Control, Screening, Strategies, Backtesting, Automatic Stock Downloading after closing, live free day trading data and much more

DoctorK is a service for Kafka cluster auto healing and workload balancing

all kinds of scrapy demo

A Soccer Dashboard created by scraping EPL website using Akka backend and ReactJS frontend and IBM Cloudant for object storage. IBM Cloud Foundry is used to host both frontend and backend app.

Bro IDS Dockerfile

Datafaker is a large-scale test data and flow test data generation tool. Datafaker fakes data and inserts to varied data sources. 测试数据生成工具

python通用分布式函数调度框架 pip install function_scheduling_distributed_framework

Trading API for Quedex Bitcoin Derivatives Exchange.

[https://www.sofineday.com], golang项目开发脚手架,集成最佳实践(gin+gorm+go-redis+mongo+cors+jwt+json日志库zap(支持日志收集到kafka或mongo)+消息队列kafka+微信支付宝支付gopay+api加密+api反向代理+go modules依赖管理+headless爬虫chromedp+makefile+二进制压缩+livereload热加载)

Kafka implemented in Golang with built-in coordination (No ZK dep, single binary install, Cloud Native)

High-performance Future implementation for the JVM

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

Gathers scalable tensorflow and infrastructure deployment

Apache Spark and Apache Kafka integration example

A multi-asset, multi-strategy, event-driven trade execution and management platform for running many algorithms/bots at many venues simultaneously with unified risk management and reporting. Uses MongoDB for storage and Telegram for user notifications/trade consent.

OpenMessaging Benchmark Framework

A tiny library that makes staged/pipelined CompletableFutures much easier to create and manage

Kafka consumer lag-checking application for monitoring, written in Scala and Akka HTTP; a wrap around the Kafka consumer group command. Integrations with Cloudwatch and Datadog. Authentication recently added

My own version of r/place, done in a weekend

A small and fast async runtime for Rust

KafkaFlow is a .NET framework to consume and produce Kafka messages with multi-threading support. It's very simple to use and very extendable. You just need to install, configure, start/stop the bus with your app and create a middleware/handler to process the messages.

AKShare is an elegant and simple financial data interface library for Python, built for human beings! 开源财经数据接口库

CMAK is a tool for managing Apache Kafka clusters

Write great asynchronous code in Swift using futures and promises

Kafka Connect Tooling

专注大数据学习面试，大数据成神之路开启。Flink/Spark/Hadoop/Hbase/Hive...

Distributed Java game server, including login, gateway, game demo

Promise / Future library for Go

支持mysql、MongoDB数据变更订阅分发

Functional programming, immutable collections and FP constructs for typescript and javascript

Confluent Schema Registry for Kafka

Asynchronous TLS/SSL streams for Tokio using Rustls.

Golang Kafka consumer and producer example

分布式架构开发套件。包括缓存(一二级缓存、自动缓存管理)、队列、分布式定时任务、文件服务(七牛、阿里云OSS、fastDFS)、日志、搜索、分布式锁、分布式事务、集成dubbo、spring boot支持以及常用的工具包等。

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

A Java API for Developing Automated Trading Applications for the Equity, Futures, and Currency Markets

syslog-ng is an enhanced log daemon, supporting a wide range of input and output methods: syslog, unstructured text, queueing, SQL & NoSQL.

A Kafka Operator for Kubernetes

Superman是什么：构建Java 高级开发技术的知识体系，从基础不断打怪升级成为超人之路（更新中.......）

The easiest Future and Promises framework in Swift. No magic. No boilerplate.

Kafka 한국 사용자 모임에서 운영하는 meetup repository

The database purpose-built for stream processing applications.

Apache Kafka load testing "...basically a cloth bag filled with small jagged pieces of scrap iron"

Kafka 中文文档

A Swift Future/Promise library that can be used to model and transform asynchronous results

Self-contained examples of Apache Spark streaming integrated with Apache Kafka.

基于 Springboot + Redis + Kafka 的秒杀系统，乐观锁 + 缓存 + 限流 + 异步，TPS 从 500 优化到 3000

Library of composable Python executors

💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算)；🚀 支持运行过程中增删topic；🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。

[DEPRECATED] A micro Web framework for Rust, based on Hyper and Tokio