polyzos / pulsar-flink-stateful-streams

Related projects: ⓘ

• david-streamlio / GottaEat
  Code for the fictitious food delivery company GottaEat used in the Pulsar In Action book
  ☆17Updated 2 years ago
• polyzos / stream-processing-with-apache-flink
  ☆37Updated last month
• david-streamlio / pulsar-in-action
  The code repository for the "Pulsar in Action" book by Manning press
  ☆47Updated 2 years ago
• kgshukla / data-streaming-kafka-quarkus
  Solving data streaming problems using joins, processor, punctuator and state store
  ☆11Updated 3 years ago
• startreedata / pinot-recipes
  This repository contains recipes for Apache Pinot.
  ☆23Updated 3 weeks ago
• hazelcast / big-data-benchmark
  ☆13Updated last year
• bartosz25 / spark-scala-playground
  Sample processing code using Spark 2.1+ and Scala
  ☆50Updated 4 years ago
• nbuesing / kafka-streams-dashboards
  A demonstration of dashboards for monitoring Kafka Streams applications.
  ☆37Updated 10 months ago
• mckeeh3 / akka-java-cluster-singleton
  Akka Java cluster singleton example
  ☆10Updated 9 months ago
• confluentinc / learn-apache-flink-101-exercises
  ☆2Updated last year
• datastax / pulsar-sink
  An Apache Pulsar® sink for transferring events/messages from Pulsar topics to Apache Cassandra®, DataStax Astra or DataStax Enterprise (D…
  ☆14Updated last week
• DataStax-Examples / kafka-connector-sink-json
  Ingest JSON records from Kafka to multiple tables in the database using the DataStax Apache Kafka Connector
  ☆13Updated last year
• findinpath / testcontainers-kafka-connect
  kafka-connect-jdbc system test based on testcontainers
  ☆12Updated 11 months ago
• sjwiesman / flink-scala-3
  ☆35Updated 2 years ago
• twalthr / flink-api-examples
  Examples for using Apache Flink® with DataStream API, Table API, Flink SQL and connectors such as MySQL, JDBC, CDC, Kafka.
  ☆55Updated 11 months ago
• bakdata / streams-bootstrap
  Utility functions and base classes for Kafka Streams applications
  ☆29Updated 3 weeks ago
• conduktor / conduktor-gateway-demos
  Demos using Conduktor Gateway
  ☆15Updated 5 months ago
• confluentinc / castle
  Castle is a test harness for Apache Kafka, Trogdor, and related projects.
  ☆0Updated 4 months ago
• projectnessie / nessie-demos
  Demos for Nessie. Nessie provides Git-like capabilities for your Data Lake.
  ☆28Updated 2 weeks ago
• MrPowers / scalatest-example
  Testing Scala code with scalatest
  ☆11Updated last year
• streamnative / streamnative-academy
  ☆11Updated 11 months ago
• lightbend / microprofile-reactive-streams
  ☆13Updated last year
• srfrnk / k8s-flink-operator
  A kubernetes CRD and controller to manage Flink jobs running on your any Flink Job Manager
  ☆8Updated this week
• irajhedayati / savro
  Some Avro operations in Scala
  ☆10Updated last year
• kineticedge / kafka-streams-dashboards
  showcases Grafana dashboards for Kafka Stream applications leveraging client JMX metrics.
  ☆37Updated last month
• alvinj / ScalaCookbook2Examples
  Source code examples for the Second Edition of the Scala Cookbook
  ☆47Updated last year
• cyanfr / dbvis_to_hortonworks_hiveserver2
  Connect DBVisualizer to Hortonwork HiveServer2
  ☆9Updated 9 years ago
• ververica / lab-flink-repository-analytics
  ☆18Updated 3 months ago
• bartosz25 / acid-file-formats
  Code for Apache Hudi, Apache Iceberg and Delta Lake analysis
  ☆9Updated 7 months ago
• nbuesing / quizzer
  An interactive quiz application build on Kafka Streams, Spring MVC handler, and Vue
  ☆12Updated 4 years ago