607 Open source projects that are alternatives of or similar to Ruby Kafka

🎩 Most advanced high level Node.js Kafka client

Apache Kafka bridge

Simplifying Kafka for ruby apps

OpenTracing Instrumentation for Apache Kafka Client

A modern Apache Kafka client for node.js

Framework for Apache Kafka based Ruby and Rails applications development.

Kafka client for functional streams for scala (fs2)

Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data

Kafka proxy with a simple API, speaking the Redis protocol

Production-ready, stable Kafka client for PHP

Kafka library in Go

Kafka-based Job Queue for Python

franz-go contains a high performance, pure Go library for interacting with Kafka from 0.8.0 through 2.7.0+. Producing, consuming, transacting, administrating, etc.

Open-Source Web GUI for Apache Kafka Management

A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka

Sarama is a Go library for Apache Kafka 0.8, and up.

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

Confluent's Apache Kafka .NET client

asyncio client for kafka

This project contains examples which demonstrate how to deploy analytic models to mission-critical, scalable production environments leveraging Apache Kafka and its Streams API. Models are built with Python, H2O, TensorFlow, Keras, DeepLearning4 and other technologies.

Kafka client written in Twisted Python

Terminal output paging - cross-platform, major ruby interpreters

JWT token authentication with devise and rails

Ruby gem to print exception backtrace nicely

SparkStreaming中利用MySQL保存Kafka偏移量保证0数据丢失

GraphQL Rust Demo

CLI tools for monitoring and managing Apache Kafka

A real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernetes deployed on the cloud

Encrypted & plain text credentials for multiple environments

weiboAd Infrastructure Data Processor : kafka consumer embedded Lua scripting language in data process framework

Kafka Akka.Streams connectors - part of the Alpakka project

This is an example of real time stream processing using Spark Streaming, Kafka & Elasticsearch.

MySQL to NoSQL real time dataflow

Demo applications and code examples for Confluent Platform and Apache Kafka

Another app which used to monitor the progress of Kafka Producer and Consumer

必看！java后端，亮剑诛仙。java发展路线技术要点。

Cross-platform implementation of Unix `which` command

Simple learning project pushing CSV data into Kafka then indexing the data in ElasticSearch

💥 A simple multi-purpose connection pool client (Kafka & Hbase & Redis & RMDB & Socket & Http)

Tool to ease and automate Apache Kafka cluster configuration management

Apache Kafka support for Ruby Object Mapper

🎯 🌟[大数据面试题]分享自己在网络上收集的大数据相关的面试题以及自己的答案总结.目前包含Hadoop/Hive/Spark/Flink/Hbase/Kafka/Zookeeper框架的面试题知识总结

基于utgard的OPC DA客户端

The Ruby DataMining Gem, is a little collection of several Data-Mining-Algorithms

Distributed Stream and Batch Processing

Apache Kafka Web UI for exploring messages, consumers, configurations and more with a focus on a good UI & UX.

Yet another Web UI for KSQL

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

[DEPRECATED] Docker images for Confluent Platform.

Kubernetes Universal Declarative Operator (KUDO)

50+ DockerHub public images for Docker & Kubernetes - Hadoop, Kafka, ZooKeeper, HBase, Cassandra, Solr, SolrCloud, Presto, Apache Drill, Nifi, Spark, Consul, Riak, TeamCity and DevOps tools built on the major Linux distros: Alpine, CentOS, Debian, Fedora, Ubuntu

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]

Ruby wrapper and CLI for the GitLab REST API

Kafka connect Elastic sink connector, with just in time index/delete behaviour.

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 Certs, Yum Security Updates, Kubernetes, Cloudera etc...

Humanize elapsed time from some Time instance to Time.now, e.g. '2 hours and 1 minute ago'. ATTENTION: NOT MAINTAINED

This Scrapy project uses Redis and Kafka to create a distributed on demand scraping cluster.

Ruby gem for GrooveHQ api

Files needed to try out KSQL Recipes for yourself

Kafka Connect Elasticsearch Source