polyzos / pulsar-flink-stateful-streams
☆15Updated 2 years ago
Related projects ⓘ
Alternatives and complementary repositories for pulsar-flink-stateful-streams
- The code repository for the "Pulsar in Action" book by Manning press☆47Updated 2 years ago
- Code for the fictitious food delivery company GottaEat used in the Pulsar In Action book☆17Updated 2 years ago
- This repository contains recipes for Apache Pinot.☆24Updated last week
- showcases Grafana dashboards for Kafka Stream applications leveraging client JMX metrics.☆38Updated 2 weeks ago
- Solving data streaming problems using joins, processor, punctuator and state store☆11Updated 3 years ago
- ☆43Updated 3 months ago
- Demos for Nessie. Nessie provides Git-like capabilities for your Data Lake.☆28Updated 2 weeks ago
- Demos using Conduktor Gateway☆16Updated 7 months ago
- A demonstration of dashboards for monitoring Kafka Streams applications.☆37Updated last year
- An Apache Pulsar® sink for transferring events/messages from Pulsar topics to Apache Cassandra®, DataStax Astra or DataStax Enterprise (D…☆14Updated last month
- Sample processing code using Spark 2.1+ and Scala☆51Updated 4 years ago
- ☆13Updated last year
- Is using KoP (Kafka-On-Pulsar) a good idea? Use the scenarios implemented in this repository to check whether Pulsar with KoP enabled is …☆10Updated 2 years ago
- Realtime feedback of Akka Stream processing via WebSockets☆16Updated 4 years ago
- A collection of examples of Kafka Streams being used in production. Contributions welcome!☆40Updated 3 months ago
- kafka-connect-jdbc system test based on testcontainers☆13Updated last year
- ☆18Updated 2 years ago
- Utility functions and base classes for Kafka Streams applications☆29Updated 3 weeks ago
- Kafka Interceptor for Zipkin☆35Updated 2 years ago
- ☆13Updated 2 weeks ago
- Ingest JSON records from Kafka to multiple tables in the database using the DataStax Apache Kafka Connector☆13Updated 2 years ago
- Sample files for Pinot tutorial☆17Updated 6 months ago
- Convert XSD -> AVSC and XML -> AVRO☆36Updated 3 years ago
- 🌟 Examples of use cases that utilize Decodable, as well as demos for related open-source projects such as Apache Flink, Debezium, and Po…☆57Updated this week
- ☆29Updated 10 months ago
- Effective Kafka☆50Updated 2 years ago
- Examples for using Apache Flink® with DataStream API, Table API, Flink SQL and connectors such as MySQL, JDBC, CDC, Kafka.☆58Updated last year