403 Open source projects that are alternatives of or similar to Node Rdkafka

The Apache Kafka C/C++ library

Learn the Confluent Schema Registry & REST Proxy

Golang Kafka consumer and producer example

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

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

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

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

Bro IDS Dockerfile

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.

Spring Boot 2.x code examples

a Rocket-fast SYStem for LOG processing

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

Production-ready, stable Kafka client for PHP

Confluent Schema Registry for Kafka

all kinds of scrapy demo

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

Apache Spark and Apache Kafka integration example

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

A CLI and Go client for Kafka Schema Registry

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

Java生态研究(Spring Boot + Redis + Dubbo + RocketMQ + Elasticsearch)🔥🔥🔥🔥🔥

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

CMAK is a tool for managing Apache Kafka clusters

OpenTracing Instrumentation for Apache Kafka Client

springboot和dubbo、netty的集成，redis mongodb的nosql模板， kafka rocketmq rabbit的MQ模板， solr solrcloud elasticsearch查询引擎

❤for real-time DataOps - where the application and data fabric blends - Lenses

PG数据同步工具（Java实现）

This repo contains my notes on working with Go and computer systems.

Avro SerDe for Apache Spark structured APIs.

Reliable messages resolve distributed transactions

Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.

Bireme is an incremental synchronization tool for the Greenplum / HashData data warehouse

Community driven, reusable components for distributed apps

一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024

Load data from Kafka to any data warehouse

Machine Learning Platform and Recommendation Engine built on Kubernetes

Python Stream Processing. A Faust fork

An opinionated Elixir wrapper around brod, the Erlang Kafka client, that supports encrypted connections to Heroku Kafka out of the box.

a command-line Protobuf parser with Kafka support and JSON output

This is a Platform that collects all the data accuring in your Application and shows the data in real time by using Kibana or other tools.

Extended datasource support for Spark/Hadoop on Aliyun E-MapReduce.

A solution to help you build automation and gitops in your Apache Kafka deployments. The Kafka gitops!

docker compose files to create a fully working kafka stack

Spring Boot application showing basic configuration to work with Kafka

Neo4j Kafka Integrations, Docs =>

Command Dispatcher, Processor, and Distributed Task Queue

Kafka Docker for development. Kafka, Zookeeper, Schema Registry, Kafka-Connect, Landoop Tools, 20+ connectors

A REPL for Apache Kafka

Metronome is a distributed and fault-tolerant event scheduler

equivalent to kafka-connect 🔧 for nodejs ✨🐢🚀✨

A collection of kafka-resources

Azure Event Hubs for Apache Kafka Ecosystems

Dumps state of Storm Kafka consumers

The AsyncAPI specification allows you to create machine-readable definitions of your asynchronous APIs.

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

Samsara is a real-time analytics platform

This library wraps Kafka's embedded test cluster, allowing you to more easily create and run integration tests using JUnit against a "real" kafka server running within the context of your tests. No need to stand up an external kafka cluster!

[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热加载)