549 Open source projects that are alternatives of or similar to Java Kafka Client

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

Lightstep distributed tracing library for Node.js and the browser

Golang app to read records from a set of kafka topics and write them to an elasticsearch cluster

Blockchain data parsing and persisting results

This is a NodeJS/Angular 2 frontend UI for Kafka cluster monitoring with Burrow

Jaeger Bindings for Go OpenTracing API.

Drain log template miner in Python3

Example end to end data engineering project.

kafka-connect-s3 : Ingest data from Kafka to Object Stores(s3)

A set of tools and examples to run a flow-pipeline (sFlow, NetFlow)

Kafka Akka.Streams connectors - part of the Alpakka project

Streaming data changes to a Data Lake with Debezium and Delta Lake pipeline

大数据入门指南 ⭐

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

A real-time data replication platform that "unbundles" the receiving, transforming, and transport of data streams.

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

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

Kafka backed service library.

An Event Sourcing service template with DDD, TDD and SOLID. It has High Cohesion and Loose Coupling, it's a good start for your next Microservice application.

OpenTracing Instrumentation for gRPC

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...

golang kafka consumer group

A library provides consumer/producer to work with kafka, avro and schema registry

Kafka exporter for Prometheus

Support for OpenTracing in Erlang

以Kafka为存储介质，提供异步Http RPC的中间件

Open-source IoT Platform - Device management, data collection, processing and visualization.

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

GraphQL Rust Demo

Real-time analysis of bitcoin markets with Kafka and Tensorflow Serving

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

Tool to ease and automate Apache Kafka cluster configuration management

关于kafka的一些相关使用示例代码。

Ansible Kafka role

基于utgard的OPC DA客户端

Bridge between OpenTracing and Brave

Package core is a service container that elegantly bootstrap and coordinate twelve-factor apps in Go.

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

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

A web client for visualizing your Apache Kafka topics live.

kafka php client

.NET event stream projection and scheduling platform with EventStore, CosmosDb, Equinox and Kafka integrations

Deep Learning UDF for KSQL, the Streaming SQL Engine for Apache Kafka with Elasticsearch Sink Example

Files needed to try out KSQL Recipes for yourself

De-/Serialization wrapper for Kafka to accomplish end to end encryption

Automated documentation for async APIs built with Spring Boot

This toolkit is focused on interacting with popular messaging systems such as Kafka, JMS, XMS, and MQTT. After release v5.4.2 the complete toolkit will be deprecated. See the README.md file for hints to alternative toolkits.

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

Karapace - Your Kafka essentials in one tool

Camel Kafka Connector allows you to use all Camel components as Kafka Connect connectors

Kafka client written in Twisted Python

OpenTracing instrumentation for Vert.x web package

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

个人学习知识库涉及到数据仓库建模、实时计算、大数据、Java、算法等。

A bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.

Ansible playbook to deploy distributed technologies

SOFATracer is a component for the distributed system call trace. And through a unified traceId logging the logs of various network calls in the invoking link. These logs can be used for quick discovery of faults, service governance, etc.

MySQL to NoSQL real time dataflow