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

Code and presentation for Strata Model Serving tutorial

Monitoring tool to measure flow throughput of data sources and processing components that are part of Data Ingestion and ETL pipelines.

A Python implementation of Apache Kafka Streams

OpenTracing Instrumentation for Redis Client

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

OpenTracing Java JAX-RS instrumentation

A fast data collector in Rust

Out of the box distributed tracing for Node.js applications.

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

简单易用的微服务框架 | Ease used microservice framework

NetDiscovery 是一款基于 Vert.x、RxJava 2 等框架实现的通用爬虫框架/中间件。

Exports cross-process metrics via OpenTracing to Prometheus.

大数据入门指南 ⭐

An MicroProfile-OpenTracing implementation

GoFrame is a modular, powerful, high-performance and enterprise-class application development framework of Golang.

The Lightstep distributed tracing library for JRE

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

Kafka with KafkaReactor and Kafka Streams Examples in Kotlin

程序员进阶书籍（视频），持续更新（Programmer Books）

Kafka Streams demo project containing Derivative Events, the Processor Api and Wall-clock examples

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

Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.

dnc 去中心化 开源社区 轻联盟 dncto.com QQ群 779699538

[WIP] OpenTracing Tracer implementation for Datadog in Go

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

Gin Web Framework for using Logrus as the Gin logger with Tracing middleware

Kafka backed service library.

Event-Driven microservices with Kafka Streams

A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems.

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.

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

Terraform and Ansible to install a Kafka Cluster

Real Time Analytics and Data Pipelines based on Spark Streaming

An umbrella project for multiple implementations of model serving

golang kafka consumer group

OpenTracing instrumentation for GORM.

golang版本的hangout, 希望能省些内存. 使用了自己写的Kafka lib .. 虚. 不过我们在生产环境已经使用近1年, kafka 版本从0.9.0.1到2.0都在使用, 目前情况稳定. 吞吐量在每天2000亿条以上.

[DEPRECATED] OpenTracing tracer implementation for Datadog in JavaScript.

Kafka exporter for Prometheus

OpenTracing-aware helpers related to java.util.concurrent

Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern

Curated by Lenses.io

Support for OpenTracing in Erlang

Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.

A Kafka Operator for Kubernetes

GraphQL Rust Demo

Kafka Development Tool

A Manageable, Measurable and Traceable Node.js Application Manager represented by Alibaba powered by TypeScript

Building event-driven applications the easy way in Go.

Oh no! Yet another Kafka operator for Kubernetes

docker-compose.yml files for cp-all-in-one , cp-all-in-one-community, cp-all-in-one-cloud

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

A CLI tool for Kafka

前端性能监控系统,消息队列,高可用,集群等相关架构

MOVED TO https://github.com/opentracing/opentracing-php

Surging is a micro-service engine that provides a lightweight, high-performance, modular RPC request pipeline. The service engine supports http, TCP, WS,Grpc, Thrift,Mqtt, UDP, and DNS protocols. It uses ZooKeeper and Consul as a registry, and integrates it. Hash, random, polling, Fair Polling as a load balancing algorithm, built-in service gove…

KafkaCenter is a unified platform for Kafka cluster management and maintenance, producer / consumer monitoring, and use of ecological components.

Experimental CQRS and Event Sourcing service

Ansible playbooks for the Confluent Platform

一个仿照牛客网实现的讨论社区，不仅实现了基本的注册，登录，发帖，评论，点赞，回复功能，同时使用前缀树实现敏感词过滤，使用wkhtmltopdf生成长图和pdf，实现网站UV和DAU统计，并将用户头像等信息存于七牛云服务器。