Go StreamsA lightweight stream processing library for Go
Stars: ✭ 615 (+48.91%)
Pg2kafkaShip changes in Postgres 🐘 to Kafka 📖
Stars: ✭ 61 (-85.23%)
SamsaraSamsara is a real-time analytics platform
Stars: ✭ 132 (-68.04%)
Fs2 KafkaKafka client for functional streams for scala (fs2)
Stars: ✭ 75 (-81.84%)
WatermillBuilding event-driven applications the easy way in Go.
Stars: ✭ 3,504 (+748.43%)
BenthosFancy stream processing made operationally mundane
Stars: ✭ 3,705 (+797.09%)
Streamsx.messagingThis 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.
Stars: ✭ 31 (-92.49%)
FaustPython Stream Processing
Stars: ✭ 5,899 (+1328.33%)
ExamplesDemo applications and code examples for Confluent Platform and Apache Kafka
Stars: ✭ 571 (+38.26%)
Neo4j StreamsNeo4j Kafka Integrations, Docs =>
Stars: ✭ 126 (-69.49%)
Hazelcast JetDistributed Stream and Batch Processing
Stars: ✭ 855 (+107.02%)
Go Kafka ExampleGolang Kafka consumer and producer example
Stars: ✭ 108 (-73.85%)
Storm Dynamic SpoutA framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.
Stars: ✭ 40 (-90.31%)
LogislandScalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.
Stars: ✭ 97 (-76.51%)
Flink Learningflink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
Stars: ✭ 11,378 (+2654.96%)
Kafka Streamsequivalent to kafka-streams 🐙 for nodejs ✨🐢🚀✨
Stars: ✭ 613 (+48.43%)
KsqlThe database purpose-built for stream processing applications.
Stars: ✭ 4,668 (+1030.27%)
KsppA high performance/ real-time C++ Kafka streams framework (C++17)
Stars: ✭ 80 (-80.63%)
Ferolight, fast, scalable, streaming microservices made easy
Stars: ✭ 175 (-57.63%)
Kafka WebviewFull-featured web-based Apache Kafka consumer UI
Stars: ✭ 319 (-22.76%)
KafdropKafka UI and Monitoring Tool
Stars: ✭ 366 (-11.38%)
Kafka GoKafka library in Go
Stars: ✭ 4,200 (+916.95%)
WedatasphereWeDataSphere is a financial level one-stop open-source suitcase for big data platforms. Currently the source code of Scriptis and Linkis has already been released to the open-source community. WeDataSphere, Big Data Made Easy!
Stars: ✭ 372 (-9.93%)
ZatZeek Analysis Tools (ZAT): Processing and analysis of Zeek network data with Pandas, scikit-learn, Kafka and Spark
Stars: ✭ 303 (-26.63%)
Micronaut Microservices PocVery simplified insurance sales system made in a microservices architecture using Micronaut
Stars: ✭ 394 (-4.6%)
Yomo🦖 Streaming-Serverless Framework for Low-latency Edge Computing applications, running atop QUIC protocol, engaging 5G technology.
Stars: ✭ 279 (-32.45%)
TrubkaA CLI tool for Kafka
Stars: ✭ 296 (-28.33%)
SmooksAn extensible Java framework for building XML and non-XML streaming applications
Stars: ✭ 293 (-29.06%)
Spiderman基于 scrapy-redis 的通用分布式爬虫框架
Stars: ✭ 392 (-5.08%)
SurgingSurging 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…
Stars: ✭ 3,088 (+647.7%)
Scalatest Embedded KafkaA library that provides an in-memory Kafka instance to run your tests against.
Stars: ✭ 292 (-29.3%)
ZenkoZenko is the open source multi-cloud data controller: own and keep control of your data on any cloud.
Stars: ✭ 353 (-14.53%)
Scala Kafka ClientScala helper modules for operating the Apache Kafka client library (0.9.x - 2.1.0)
Stars: ✭ 348 (-15.74%)
Cp AnsibleAnsible playbooks for the Confluent Platform
Stars: ✭ 285 (-30.99%)
Kafka KitKafka storage rebalancing, automated replication throttle, cluster API and more
Stars: ✭ 346 (-16.22%)
Cp DemoConfluent Platform Demo including Apache Kafka, ksqlDB, Control Center, Replicator, Confluent Schema Registry, Security
Stars: ✭ 278 (-32.69%)
Fw Spring CloudSpringCloud构建实战、从入门到高级,包含eureka、zuul、gateway、feign、ribbon、hystrix、mq、turbine、nacos、elk、consul、zookeeper、rocketmq、kafka、分布式事务(RocketMq、LCN、Seata)、分库分表(Sharding-JDBC)、分布式锁(Redis、Guava)、jwt、SkyWalking、Zipkin、bootadmin等使用案例
Stars: ✭ 276 (-33.17%)
GnomockTest your code without writing mocks with ephemeral Docker containers 📦 Setup popular services with just a couple lines of code ⏱️ No bash, no yaml, only code 💻
Stars: ✭ 398 (-3.63%)
Springboot Learning基于Gradle构建,使用SpringBoot在各个场景的应用,包括集成消息中间件、前后端分离、数据库、缓存、分布式锁、分布式事务等
Stars: ✭ 340 (-17.68%)
KminionKMinion is a feature-rich Prometheus exporter for Apache Kafka written in Go. It is lightweight and highly configurable so that it will meet your requirements.
Stars: ✭ 274 (-33.66%)
EventeumA resilient Ethereum event listener that bridges your smart contract events and backend microservices
Stars: ✭ 272 (-34.14%)
GizmoA Microservice Toolkit from The New York Times
Stars: ✭ 3,566 (+763.44%)
QbusbridgeThe Apache Kafka Client SDK
Stars: ✭ 272 (-34.14%)
Kafka Sprout🚀 Web GUI for Kafka Cluster Management
Stars: ✭ 388 (-6.05%)