confluentinc / Ksql Recipes Try It At Home
Files needed to try out KSQL Recipes for yourself
Stars: ✭ 33
Programming Languages
shell
77523 projects
Labels
Projects that are alternatives of or similar to Ksql Recipes Try It At Home
Kafka Tutorials
Kafka Tutorials microsite
Stars: ✭ 144 (+336.36%)
Mutual labels: kafka, stream-processing
Streamsx.messaging
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.
Stars: ✭ 31 (-6.06%)
Mutual labels: kafka, stream-processing
Kafka Streams In Action
Source code for the Kafka Streams in Action Book
Stars: ✭ 167 (+406.06%)
Mutual labels: kafka, stream-processing
Go Kafka Example
Golang Kafka consumer and producer example
Stars: ✭ 108 (+227.27%)
Mutual labels: kafka, stream-processing
Ksql
The database purpose-built for stream processing applications.
Stars: ✭ 4,668 (+14045.45%)
Mutual labels: kafka, stream-processing
Neo4j Streams
Neo4j Kafka Integrations, Docs =>
Stars: ✭ 126 (+281.82%)
Mutual labels: kafka, stream-processing
Watermill
Building event-driven applications the easy way in Go.
Stars: ✭ 3,504 (+10518.18%)
Mutual labels: kafka, stream-processing
Kspp
A high performance/ real-time C++ Kafka streams framework (C++17)
Stars: ✭ 80 (+142.42%)
Mutual labels: kafka, stream-processing
Kasper
Kasper is a lightweight library for processing Kafka topics.
Stars: ✭ 413 (+1151.52%)
Mutual labels: kafka, stream-processing
Awesome Kafka
A list about Apache Kafka
Stars: ✭ 397 (+1103.03%)
Mutual labels: kafka, stream-processing
Hazelcast Jet
Distributed Stream and Batch Processing
Stars: ✭ 855 (+2490.91%)
Mutual labels: kafka, stream-processing
Go Streams
A lightweight stream processing library for Go
Stars: ✭ 615 (+1763.64%)
Mutual labels: kafka, stream-processing
Flink Learning
flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
Stars: ✭ 11,378 (+34378.79%)
Mutual labels: kafka, stream-processing
Samsara
Samsara is a real-time analytics platform
Stars: ✭ 132 (+300%)
Mutual labels: kafka, stream-processing
Logisland
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.
Stars: ✭ 97 (+193.94%)
Mutual labels: kafka, stream-processing
Fero
light, fast, scalable, streaming microservices made easy
Stars: ✭ 175 (+430.3%)
Mutual labels: kafka, stream-processing
Pg2kafka
Ship changes in Postgres 🐘 to Kafka 📖
Stars: ✭ 61 (+84.85%)
Mutual labels: kafka, stream-processing
Fs2 Kafka
Kafka client for functional streams for scala (fs2)
Stars: ✭ 75 (+127.27%)
Mutual labels: kafka, stream-processing
Benthos
Fancy stream processing made operationally mundane
Stars: ✭ 3,705 (+11127.27%)
Mutual labels: kafka, stream-processing
Kafka Streams
equivalent to kafka-streams 🐙 for nodejs ✨🐢🚀✨
Stars: ✭ 613 (+1757.58%)
Mutual labels: kafka, stream-processing
= KSQL Recipes – Try it at home!
image::images/ksql-rocket.svg[KSQL Rocket]
This repository contains all you need to try out the KSQL recipes yourself. All you need is Docker and Docker Compose! Each recipe includes the full details on how to run it.
- link:aggregating-data[Aggregating Data]
- link:atm-fraud-detection[ATM Fraud Detection]
- link:calculating-bus-delay-time[Calculating Bus Delay Time]
- link:counting-messages-in-a-topic[Counting messages in a topic]
- link:creating-composite-key[Creating a Composite Key]
- link:data-filtering[Data Filtering]
- link:data-masking[Data Masking]
- link:detecting-abnormal-transactions[Detecting Abnormal Transactions]
- link:detecting-unusual-card-activity[Detecting Unusual Credit Card Activity]
- link:enriching-streams-static-json-file-loaded-table[Enriching Streams with Static Data Loaded as a Table]
- link:flattening-json-kafka-messages[Flattening JSON Kafka Messages]
- link:heterogeneous-json-structures[Heterogeneous JSON Structures]
- link:monitoring-network-activity[Monitoring Network Activity by User]
- link:syslog-pattern-detection-alerting[Processing Syslog Data: Pattern Detection and Alerting]
- link:setting-kafka-message-key[Setting the Kafka Message Key]
- link:sysmon-event-processing[Sysmon Event Processing]
- link:nested-json-data[Working with Nested JSON Data]
Note that the project description data, including the texts, logos, images, and/or trademarks,
for each open source project belongs to its rightful owner.
If you wish to add or remove any projects, please contact us at [email protected].