414 Open source projects that are alternatives of or similar to Phobos

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!

大数据分析可视化实践

all kinds of scrapy demo

🥚 Netty实践学习案例，见微知著！带着你的心，跟着教程。我相信你行欧。

Bro IDS Dockerfile

.NET Stream Processing Library for Apache Kafka 🚀

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

A easy and high-performance monitoring system, for comprehensive monitoring and management of 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热加载)

Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar

Kafka ecosystem ... but step by step!

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

Write your Spark data to Kafka seamlessly

Apache Spark and Apache Kafka integration example

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.

Learn the Confluent Schema Registry & REST Proxy

本人的RabbitMQ和Kafka详细笔记以及示例代码

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

汇总java生态圈常用技术框架、开源中间件，系统架构、数据库、大公司架构案例、常用三方类库、项目管理、线上问题排查、个人成长、思考等知识

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.

Mirus is a cross data-center data replication tool for Apache Kafka

CMAK is a tool for managing Apache Kafka clusters

Kafka Tutorials microsite

Kafka Connect Tooling

Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.

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

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

Apache Kafka on Docker

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

《Kafka技术内幕》代码

Confluent Schema Registry for Kafka

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

Golang Kafka consumer and producer example

Automatic instrumentation for 3rd-party libraries in Java applications with OpenTracing.

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

Confluent REST Proxy for Kafka

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

Spark Structured Streaming / Kafka / Cassandra / Elastic

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

Syslog Collector written in Go, streams to Kafka 0.8

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

Laravel Enqueue message queue extension. Supports AMQP, Amazon SQS, Kafka, Google PubSub, Redis, STOMP, Gearman, Beanstalk and others

A CLI and Go client for Kafka Schema Registry

Spring Boot application showing basic configuration to work with Kafka

Spring Boot 2.x code examples

Collection of Kubernetes Operators built with KUDO.

Source code for the Kafka Streams in Action Book

Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.

**Unofficial / Community** Kafka Connect MongoDB Sink Connector - Find the official MongoDB Kafka Connector here: https://www.mongodb.com/kafka-connector

Command Dispatcher, Processor, and Distributed Task Queue

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

WaterDrop is a standalone Karafka component library for generating Kafka messages

A REPL for Apache Kafka

a Rocket-fast SYStem for LOG processing

Apollo graphql subscriptions over Kafka protocol

Secor is a service implementing Kafka log persistence

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

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

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