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
Practical examples with Apache Kafka®
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.
A Kafka Connect Source Connector for DynamoDB
Kafka Connect Transform to copy Avro schemas between Schema Registries
Kafka Connect Elasticsearch connector
A simple Spring Boot app that talks to Kafka using Avro and Schema Registry
Kafka Connect connector for JDBC-compatible databases
Kafka Connect HDFS connector
Showcase on producing&consuming avro messages in Apache Kafka testcontainers ecosystem
Java Examples for running Apache Flink® Table API on Confluent Cloud
Kafka, Avro and Schema Registry with Spring Boot3
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."