confluent
There are 232 repositories under confluent topic.
confluentinc/confluent-kafka-go
Confluent's Apache Kafka Golang client
confluentinc/confluent-kafka-python
Confluent's Kafka Python Client
confluentinc/confluent-kafka-dotnet
Confluent's Apache Kafka .NET client
confluentinc/kafka-rest
Confluent REST Proxy for Kafka
confluentinc/schema-registry
Confluent Schema Registry for Kafka
confluentinc/examples
Apache Kafka and Confluent Platform examples and demos
timeplus-io/proton
A streaming SQL engine, a fast and lightweight alternative to ksqlDB and Apache Flink, 🚀 powered by ClickHouse.
confluentinc/kafka-connect-jdbc
Kafka Connect connector for JDBC-compatible databases
confluentinc/cp-all-in-one
docker-compose.yml files for cp-all-in-one , cp-all-in-one-community, cp-all-in-one-cloud, Apache Kafka Confluent Platform
confluentinc/kafka-connect-elasticsearch
Kafka Connect Elasticsearch connector
vdesabou/kafka-docker-playground
🐳✨ Fully automated Apache Kafka® and Confluent Docker based examples // 👷♂️ Easily build examples or reproduction models
confluentinc/cp-demo
Confluent Platform Demo including Apache Kafka, ksqlDB, Control Center, Schema Registry, Security, Schema Linking, and Cluster Linking
confluentinc/kafka-connect-hdfs
Kafka Connect HDFS connector
confluentinc/cp-ansible
Ansible playbooks for the Confluent Platform
kaiwaehner/hivemq-mqtt-tensorflow-kafka-realtime-iot-machine-learning-training-inference
Real Time Big Data / IoT Machine Learning (Model Training and Inference) with HiveMQ (MQTT), TensorFlow IO and Apache Kafka - no additional data store like S3, HDFS or Spark required
kaiwaehner/ksql-udf-deep-learning-mqtt-iot
Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data
confluentinc/kafka-connect-storage-cloud
Kafka Connect suite of connectors for Cloud storage (Amazon S3)
confluentinc/jmx-monitoring-stacks
📊 Monitoring examples for Confluent Cloud and Confluent Platform
riferrei/srclient
Golang Client for Schema Registry
kaiwaehner/kafka-connect-iot-mqtt-connector-example
Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data
kaiwaehner/tensorflow-serving-java-grpc-kafka-streams
Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response
devshawn/kafka-shell
⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.
lensesio/schema-registry
A CLI and Go client for Kafka Schema Registry. This repository is deprecated and no longer maintained.
confluentinc/cli
CLI for Confluent Cloud and Confluent Platform
mmolimar/kafka-connect-fs
Kafka Connect FileSystem Connector
ImFlog/schema-registry-plugin
Gradle plugin to interact with Confluent Schema-Registry.
confluentinc/camus
Mirror of Linkedin's Camus
Strech/avrora
A convenient Elixir library to work with Avro schemas and Confluent® Schema Registry
confluentinc/confluent-kafka-javascript
Confluent's Apache Kafka JavaScript client
openweb-nl/open-bank-mark
A bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.
mmolimar/ksql-jdbc-driver
JDBC driver for Apache Kafka
conduktor/conduktor-platform
Streamline Apache Kafka with Conduktor Platform. 🚀
confluentinc/streaming-ops
Simulated production environment running Kubernetes targeting Apache Kafka and Confluent components on Confluent Cloud. Managed by declarative infrastructure and GitOps.
domnikl/schema-registry-gitops
Manage Confluent Schema Registry subjects through Infrastructure as code
ivangfr/springboot-kafka-connect-debezium-ksqldb
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.
oslabs-beta/kafkaESK
An event-driven monitoring tool that can consume messages from Apache Kafka clusters and display the aggregated data on a dashboard for analysis and maintenance.