Awesome Open Source

Programming Languages

Search results for stream kafka

169 search results found

Kafka Ui ⭐ 7,779

Open-Source Web UI for Apache Kafka Management

Faust ⭐ 6,637

Python Stream Processing

The database purpose-built for stream processing applications.

Liftbridge ⭐ 2,413

Lightweight, fault-tolerant message streams.

Kafka Streams Examples ⭐ 2,248

Demo applications and code examples for Apache Kafka's Streams API.

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

Flinkstreamsql ⭐ 1,972

基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法

Svix Webhooks ⭐ 1,899

The enterprise-ready webhooks service 🦀

Go Streams ⭐ 1,656

A lightweight stream processing library for Go

Faust ⭐ 1,330

Python Stream Processing. A Faust fork

Alpakka ⭐ 1,259

Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

Hazelcast Jet ⭐ 1,065

Distributed Stream and Batch Processing

Spring Cloud Stream Samples ⭐ 922

Samples for Spring Cloud Stream

Kafka Streams Machine Learning Examples ⭐ 806

This project contains examples which demonstrate how to deploy analytic models to mission-critical, scalable production environments leveraging Apache Kafka and its Streams API. Models are built with Python, H2O, TensorFlow, Keras, DeepLearning4 and other technologies.

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.

Awesome Kafka ⭐ 549

A list about Apache Kafka

Kafka Streams Course ⭐ 528

Learn Kafka Streams with several examples!

Cp Demo ⭐ 515

Confluent Platform Demo including Apache Kafka, ksqlDB, Control Center, Schema Registry, Security, Schema Linking, and Cluster Linking

Apicurio Registry ⭐ 495

An API/Schema registry - stores APIs and Schemas.

Tributary ⭐ 424

Streaming reactive and dataflow graphs in Python

Kafka Connect Github Source ⭐ 418

Get a stream of issues and pull requests for your chosen GitHub repository

Kafka Streams Dotnet ⭐ 411

.NET Stream Processing Library for Apache Kafka 🚀

Ziggurat ⭐ 383

A stream processing framework to build stateless applications on Kafka

Datafaker ⭐ 377

Datafaker is a large-scale test data and flow test data generation tool. Datafaker fakes data and inserts to varied data sources. 测试数据生成工具

Zio Kafka ⭐ 322

A Kafka client for ZIO and ZIO Streams

Spring Cloud Stream Binder Kafka ⭐ 318

Spring Cloud Stream binders for Apache Kafka and Kafka Streams

Scalatest Embedded Kafka ⭐ 290

A library that provides an in-memory Kafka instance to run your tests against.

Winton Kafka Streams ⭐ 281

A Python implementation of Apache Kafka Streams

A minimalistic 12 factor log router written in Go

Alchemy ⭐ 236

给flink开发的web系统。支持页面上定义udf，进行sql和jar任务的提交；支持source、

Kafkastreams Cep ⭐ 233

Complex Event Processing on top of Kafka Streams

Azure Event Hubs Spark ⭐ 225

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

Streaming At Scale ⭐ 224

How to implement a streaming at scale solution in Azure

Smallrye Reactive Messaging ⭐ 218

SmallRye Reactive Messaging

Kafka Streams ⭐ 210

Code examples for working with Kafka Streams

Awesome Kafka ⭐ 193

Everything about Apache Kafka

Kafka Streams Scala ⭐ 191

Thin Scala wrapper around Kafka Streams Java API

Video Stream Analytics ⭐ 191

Kafka With Akka Streams Kafka Streams Tutorial ⭐ 191

Code samples for the Lightbend tutorial on writing microservices with Akka Streams, Kafka Streams, and Kafka

Big Data ⭐ 190

一个开源、成体系的大数据学习教程。spark学习 hadoop hive hbase flink教程 linux 从入门到精通

Kafka Streams In Action ⭐ 183

Source code for the Kafka Streams in Action Book

Mockedstreams ⭐ 182

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

Kafka Streams Stockstats ⭐ 178

Kafka Streams Example - Some aggregates on fake stock data

Minibatch ⭐ 177

Python stream processing for humans

Awesome Kafka ⭐ 175

A curated list of awesome things related to Apache Kafka

Azkarra Streams ⭐ 168

🚀 Azkarra is a lightweight java framework to make it easy to develop, deploy and manage cloud-native streaming microservices based on Apache Kafka Streams.

Kafka Book ⭐ 167

《Kafka技术内幕》代码

Neo4j Streams ⭐ 165

Neo4j Kafka Connector

Unifrost ⭐ 163

A go module that makes it easier to stream pubsub messages to the browser by relaying them via Server Sent Events (EventSource).

Amazonriver ⭐ 162

amazonriver 是一个将postgresql的实时数据同步到es或kafka的服务

Spark Streaming With Kafka ⭐ 161

Self-contained examples of Apache Spark streaming integrated with Apache Kafka.

Kafka Rx ⭐ 160

reactive kafka client

Awesome Kafka ⭐ 159

A collection of kafka-resources

Spark Structured Streaming Examples ⭐ 153

Spark Structured Streaming / Kafka / Cassandra / Elastic

a command-line Protobuf parser with Kafka support and JSON output

Distributed notifications using websockets

Kinesis Kafka Connector ⭐ 136

kinesis-kafka-connector is connector based on Kafka Connect to publish messages to Amazon Kinesis streams or Amazon Kinesis Firehose.

Kafka Ml ⭐ 131

Kafka-ML: connecting the data stream with ML/AI frameworks (now TensorFlow and PyTorch!)

A Clojure DSL for Kafka Streams

PG数据同步工具（Java实现）

Stream Registry ⭐ 113

Stream Discovery and Stream Orchestration

Kafkaexample ⭐ 111

Illuminati ⭐ 111

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.

Confluent Kafka Certification ⭐ 108

This repos is to keep all the relevant informations for Confluent Certified Developer for Apache Kafka (CCDAK)

Embedded Kafka Schema Registry ⭐ 106

A library that provides in-memory instances of both Kafka and Confluent Schema Registry to run your tests against.

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 Streams Clojure ⭐ 95

Clojure transducers interface to Kafka Streams

Event Streams Samples ⭐ 93

Kafkastreams4s ⭐ 90

Kafka Streams for Scala. Integrates KafkaStreams with the cats-effect ecosystem

Qstreaming ⭐ 89

A simplified, lightweight ETL pipeline framework for build stream/batch processing applications on top of Apache Spark

Kafta is a command line for managing Kafka clusters

Fluent Kafka Streams Tests ⭐ 86

Fluent Kafka Streams Test with Java

Tensorflow Serving Java Grpc Kafka Streams ⭐ 85

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

Reactive Kafka Microservice Template ⭐ 84

An example of a microservice template which uses akka/reactive-kafka to stream JSON messages

Springboot Kafka Connect Jdbc Streams ⭐ 82

Project goal: Explore Kafka, Kafka Connect, and Kafka Streams. Components: store-api: Inserts/updates MySQL records. Source Connectors: Monitor MySQL changes, push messages to Kafka. Sink Connectors: Listen to Kafka, insert/update Elasticsearch docs. store-streams: Listens to Kafka, processes with Kafka Streams, pushes new messages to Kafka.

Micronaut Kafka ⭐ 80

Integration between Micronaut and Apache Kafka

Vertx Kafka Client ⭐ 80

Reactive Kafka Client for Vert.x

Awesome Opensource Contribs Kafka ⭐ 80

A list of all awesome open-source contributions for the Apache Kafka project

Reference engine for composable applications

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.

Kafka Connect Twitter ⭐ 75

Kafka Connect Sink/Source for Twitter

Product Sp ⭐ 74

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

Kafkaesk ⭐ 73

An event-driven monitoring tool that can consume messages from Apache Kafka clusters and display the aggregated data on a dashboard for analysis and maintenance.

Clojure Kafka Examples ⭐ 72

Clojure examples for Kafka and Kafka Streams (JAVA Interop)

Hello Kafka Streams ⭐ 71

Wikipedia stream-processing demo using Kafka Connect and Kafka Streams.

Kafka Streams Query ⭐ 71

Library offering http based query on top of Kafka Streams Interactive Queries

Orleans.streams.kafka ⭐ 68

An implementation of a PersistentStreamProvider for Microsoft Orleans and Kafka using the Confluent API

Delta Architecture ⭐ 66

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

Akka.streams.kafka ⭐ 66

Kafka Akka.Streams connectors - part of the Alpakka project

Client Examples ⭐ 66

Example clients for use with Strimzi

Kafka Shell ⭐ 65

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

Intro To Akka Streams ⭐ 65

Kafka Streams Ex ⭐ 61

A collection of examples and use-cases for Kafka Streams

Dataworks ⭐ 61

Hot-swap API endpoints and stream processors using Clojure and Dataworks

Experiments in Streaming

Ksql Fork With Deep Learning Function ⭐ 58

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

Kafka Workshop ⭐ 58

Materials (slides and code) for Kafka and Kafka Streams Workshops

Data Stream Development With Apache Spark Kafka And Spring Boot ⭐ 54

Data Stream Development with Apache Spark, Kafka and Spring Boot by Packt Publishing

Related Searches

Javascript Stream (6,703)

Java Kafka (3,237)

Python Stream (2,326)

Java Stream (2,181)

Stream Streaming (1,713)

Kafka Zookeeper (1,229)

Docker Kafka (1,123)

Python Kafka (1,053)

C Plus Plus Stream (1,031)

Spark Kafka (979)

1-100 of 169 search results

Privacy | About | Terms | Follow Us On Twitter

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