confluent
There are 243 repositories under confluent topic.
confluentinc/confluent-kafka-go
Confluent's Apache Kafka Golang client
confluentinc/schema-registry
Confluent Schema Registry for Kafka
confluentinc/examples
Apache Kafka, Apache Flink and Confluent Platform examples and demos
timeplus-io/proton
High-performance, low-footprint SQL database written in C++. Process millions of rows per second from Kafka, Pulsar, or ClickHouse, and seamlessly write results back. Supports powerful features like JOIN, CDC, UPSERT, and LOOKUP, enabling real-time analytics and ETL at scale.
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
vdesabou/kafka-docker-playground
🐳✨ Fully automated Apache Kafka® and Confluent Docker based examples // 👷♂️ Easily build examples or reproduction models
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
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
confluentinc/confluent-kafka-python
Confluent's Kafka Python Client
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.
conduktor/conduktor-platform
Streamline Apache Kafka with Conduktor Platform. 🚀
ImFlog/schema-registry-plugin
Gradle plugin to interact with Confluent Schema-Registry.
mmolimar/kafka-connect-fs
Kafka Connect FileSystem Connector
confluentinc/confluent-kafka-javascript
Confluent's Apache Kafka JavaScript client
confluentinc/confluent-kafka-dotnet
Confluent's Apache Kafka .NET client
Strech/avrora
A convenient Elixir library to work with Avro messages, schemas and Confluent® Schema Registry
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.
domnikl/schema-registry-gitops
Manage Confluent Schema Registry subjects through Infrastructure as code
mmolimar/ksql-jdbc-driver
JDBC driver for Apache Kafka
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.
jonathansant/Orleans.Streams.Kafka
An implementation of a PersistentStreamProvider for Microsoft Orleans and Kafka using the Confluent API
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.
confluentinc/jmx-monitoring-stacks
📊 Monitoring examples for Confluent Cloud and Confluent Platform
flix-tech/avro-serde-php
Avro Serialisation/Deserialisation (SerDe) library for PHP 8.1+ with a Symfony Serializer integration
hifly81/kafka-examples
Practical examples with Apache Kafka®
confluentinc/kafka-rest
Confluent REST Proxy for Kafka
trustpilot/kafka-connect-dynamodb
A Kafka Connect Source Connector for DynamoDB
confluentinc/cli
CLI for Confluent Cloud and Confluent Platform
OneCricketeer/schema-registry-transfer-smt
Kafka Connect Transform to copy Avro schemas between Schema Registries
ifnesi/python-kafka-microservices
Implementing an Event Sourcing/CQRS microservices with Apache Kafka
flix-tech/schema-registry-php-client
A PHP 8+ API client for the Confluent Schema Registry REST API based on Guzzle 7 - http://docs.confluent.io/current/schema-registry/docs/index.html
confluentinc/cp-ansible
Ansible playbooks for the Confluent Platform