Confluent Schema Registry for Kafka
Apache Kafka, Apache Flink and Confluent Platform examples and demos
Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data
Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response
Confluent REST Proxy for Kafka
Kafka Connect FileSystem Connector
Experiment with Kafka, Debezium, and ksqlDB. research-service: Performs MySQL record manipulation. Source Connectors: Monitor MySQL changes, push messages to Kafka. Sink Connectors and kafka-research-consumer: Listen to Kafka, insert/update Elasticsearch. ksqlDB-Server: Listens to Kafka, performs joins, and pushes new messages to new Kafka topics.
Practical examples with Apache Kafka®
A Kafka Connect Source Connector for DynamoDB
Kafka Connect Transform to copy Avro schemas between Schema Registries
A simple Spring Boot app that talks to Kafka using Avro and Schema Registry
Kafka Connect Elasticsearch connector
Kafka Connect connector for JDBC-compatible databases
Kafka Connect HDFS connector
Showcase on producing&consuming avro messages in Apache Kafka testcontainers ecosystem
Kafka, Avro and Schema Registry with Spring Boot3
Java Examples for running Apache Flink® Table API on Confluent Cloud
Shared software among connectors that target distributed filesystems and cloud storage.
Add a description, image, and links to the confluent topic page so that developers can more easily learn about it.
To associate your repository with the confluent topic, visit your repo's landing page and select "manage topics."