Awesome Open Source

Programming Languages

Search results for kafka stream processing

stream-processing x

91 search results found

Flink Learning ⭐ 13,801

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

Redpanda ⭐ 8,709

Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!

Benthos ⭐ 7,564

Fancy stream processing made operationally mundane

Faust ⭐ 6,637

Python Stream Processing

Watermill ⭐ 6,498

Building event-driven applications the easy way in Go.

Risingwave ⭐ 5,799

The distributed streaming database. Engineered to offer the simplest and most cost-efficient way for stream processing and management.

The database purpose-built for stream processing applications.

Materialize ⭐ 5,547

The data warehouse for operational workloads.

Arroyo ⭐ 2,914

Distributed stream processing engine in Rust

Memgraph ⭐ 1,942

Open-source graph database, built for real-time streaming data, compatible with Neo4j.

Go Streams ⭐ 1,656

A lightweight stream processing library for Go

Faststream ⭐ 1,485

FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.

Faust ⭐ 1,330

Python Stream Processing. A Faust fork

Peerdb ⭐ 1,315

Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage

Hazelcast Jet ⭐ 1,065

Distributed Stream and Batch Processing

Kafka Streams ⭐ 797

equivalent to kafka-streams 🐙 for nodejs ✨🐢🚀✨

Hstream ⭐ 668

HStreamDB is an open-source, cloud-native streaming database for IoT and beyond. Modernize your data stack for real-time applications.

Nussknacker ⭐ 564

Low-code tool for automating actions on real time data | Stream processing for the users.

Awesome Kafka ⭐ 549

A list about Apache Kafka

Kasper is a lightweight library for processing Kafka topics.

Quix Streams ⭐ 334

Quix Streams - A library for data streaming and Python Stream Processing

Kafka Tutorials ⭐ 291

Tutorials and Recipes for Apache Kafka

Kafka Streams In Action ⭐ 183

Source code for the Kafka Streams in Action Book

light, fast, scalable, streaming microservices made easy

Neo4j Streams ⭐ 165

Neo4j Kafka Connector

Dolphinbeat ⭐ 153

A server that pulls and parses MySQL binlog, pushs change data into different sinks like Kafka.

Go Kafka Example ⭐ 149

Golang Kafka consumer and producer example

Samsara ⭐ 120

Samsara is a real-time analytics platform

Remotecodecompiler ⭐ 117

An online code compiler supporting 11 programming languages (Java, Kotlin, Scala, C, C++, C#, Golang, Python, Ruby, Rust and Haskell) for competitive programming and coding interviews.

Stream Registry ⭐ 113

Stream Discovery and Stream Orchestration

Logisland ⭐ 106

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

A high performance/ real-time C++ Kafka streams framework (C++17)

Kafka Spark Streaming Example ⭐ 96

Simple examle for Spark Streaming over Kafka topic

Tensorflow Serving Java Grpc Kafka Streams ⭐ 85

Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response

Functional programming with Kafka and Scala

Kafka Streams Real Time Stream Processing ⭐ 76

This is the central repository for all materials related to Kafka Streams : Real-time Stream Processing! Book by Prashant Pandey.

Fs2 Kafka ⭐ 75

Kafka client for functional streams for scala (fs2)

Product Sp ⭐ 74

An open source, cloud-native streaming data integration and analytics product optimized for agile digital businesses

Kafka Shell ⭐ 65

⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.

Pg2kafka ⭐ 63

Ship changes in Postgres 🐘 to Kafka 📖

Ksqldb Go ⭐ 59

A Golang client for ksqlDB

Kafka Fraud Detector ⭐ 47

🚨 Simple, self-contained fraud detection system built with Apache Kafka and Python

Storm Dynamic Spout ⭐ 41

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

Eye_of_sauron ⭐ 37

Stream processing using kafka-python to track people (user input images of target) in the wild over multiple video streams.

Ksql Recipes Try It At Home ⭐ 35

Files needed to try out KSQL Recipes for yourself

A library to build streaming applications that consume from and produce to Kafka.

Streamsx.messaging ⭐ 30

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.

Kafka Workers ⭐ 28

Kafka Workers is a client library which unifies records consuming from Kafka and processing them by user-defined WorkerTasks.

Stream Processors on Kafka in Golang

Football Events ⭐ 27

Event-Driven microservices with Kafka Streams

Akka_streams_tutorial ⭐ 27

A collection of runnable and self-contained examples inspired by various akka-streams (pekko-streams) and Alpakka (Pekko connectors) docs, tutorials and blogs

Streams Bootstrap ⭐ 25

Utility functions and base classes for Kafka Streams applications

Examples ⭐ 25

This repository will contain examples of use cases that utilize Decodable streaming solution

Open Stream Processing Benchmark ⭐ 24

This repository contains the code base for the Open Stream Processing Benchmark.

Event Sourcing Kafka Streams ⭐ 24

Demo code from my talk @ Codemotion Milan 2018 - "Building event sourced systems with Kafka Streams"

Affinity ⭐ 24

Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka

Makinage ⭐ 21

Stream Processing Made Easy

Perfect Kafka ⭐ 21

An Express Swift Client of Apache Kafka 0.8, the Stream Processing Platform

Hazelcast Jet Contrib ⭐ 19

Extension modules for Hazelcast Jet

Catenae Kafka ⭐ 18

Catenae 2 – Microservices Framework for Kafka

Kahpp Oss ⭐ 18

Kafka Streams made easy with a YAML file

Kafka Streams ⭐ 17

Oh you know, just a coupla, two, tree Kafka Streams in Scala

Apachekafka ⭐ 16

A curated re-sources list for awesome Apache Kafka

Streamer ⭐ 14

streamer 实时计算引擎

An opinionated clojure framework for writing kafka machines

Python stream processing for analytics

Streamsx.kafka ⭐ 13

Repository for integration with Apache Kafka

Kafka Streams Examples ⭐ 13

The magic message bus

Wearedevs 2018 ⭐ 12

Code for my talk "Stateful & Reactive Streaming Applications Without a Database" at WeAreDevelopers 2018

Deploy Kafka pipelines to Kubernetes

Kafka Aggregator ⭐ 12

A Kafka aggregator based on the Faust Python Stream Processing library

Distributed event processing for Python based on Redis Streams

Frizzle for Apache Kafka

Minikaf is a minimal implementation of Publish / Subscriber for in memory communication.

Padogrid ⭐ 10

A comprehensive addon tool for managing data grid environments by distributed workspaces and online use case bundles

Confluent Platform Spark Streaming ⭐ 10

Working example of consuming Avro data from Kafka with Spark Streaming

A Stream Processor written in Golang that support pluggable tasks

Biggis Landuse ⭐ 9

Land use update detection

Monasca Aggregator ⭐ 9

Near real-time continuous aggregation of Monasca metrics

Floodplain Library ⭐ 8

Kotlin based stream processing framework

Event Meshinery ⭐ 8

A new Framework for asynchronous signaling of processes via Kafka/Mysql/anything.

Kafka Marklogic Connector ⭐ 8

A Kafka connector for subscribing to topics and streaming messages into MarkLogic

Flink Fault Tolerant Stream Example ⭐ 8

An example of using Flink for Fault-Tolerant Stream Processing

Codefeedr ⭐ 7

CodeFeedr core infrastructure

Xke Ratatouille ⭐ 7

💊Poison pills and Kafka Streams demo🍛🐀

Openmrs Etl ⭐ 7

openmrs - mysql - debezium - kafka - spark - scala

Kafka Streams Interactive Queries ⭐ 6

Interactive Queries in Kafka Streams

Stateful Stream Processing with Project Reactor

Spark Streaming Example ⭐ 5

Example for a spark-streaming application using Kafka, Cassandra and Stateful Stream Processing

Musik: Music recognition application

Related Searches

Java Kafka (3,363)

Kafka Zookeeper (1,229)

Docker Kafka (1,106)

Python Kafka (1,053)

Spark Kafka (1,027)

Scala Kafka (974)

Golang Kafka (919)

Apache Kafka (836)

Stream Kafka (794)

Shell Kafka (642)

1-91 of 91 search results

Privacy | About | Terms | Follow Us On Twitter

Copyright 2018-2024 Awesome Open Source. All rights reserved.