confluent

Confluent's Apache Kafka Golang client

Confluent's Kafka Python Client

Confluent's Apache Kafka .NET client

Confluent REST Proxy for Kafka

Apache Kafka and Confluent Platform examples and demos

[DEPRECATED] Docker images for Confluent Platform.

Kafka Connect connector for JDBC-compatible databases

Kafka Connect Elasticsearch connector

Kafka Connect HDFS connector

Confluent Platform Demo including Apache Kafka, ksqlDB, Control Center, Replicator, Confluent Schema Registry, Security

Ansible playbooks for the Confluent Platform

🐳 Fully automated Apache Kafka® and Confluent Docker based examples

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

System integration and performance tests

Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data

Kafka Connect suite of connectors for Cloud storage (Amazon S3)

Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data

Golang Client for Schema Registry

Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response

A CLI and Go client for Kafka Schema Registry. This repository is deprecated and no longer maintained.

⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.

Kafka Connect FileSystem Connector

Mirror of Linkedin's Camus

A bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.

JDBC driver for Apache Kafka

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.

The main goal is to play with Kafka Connect and Streams. We have store-api that inserts/updates records in MySQL; Source connectors that monitor inserted/updated records in MySQL and push messages related to those changes to Kafka; Sink connectors that read messages from Kafka and insert documents in ES; Store-streams that listens for messages in Kafka, treats them using Kafka Streams and push new messages back to Kafka.

Simulated production environment running Kubernetes targeting Apache Kafka and Confluent components on Confluent Cloud. Managed by declarative infrastructure and GitOps.

A convenient Elixir library to work with Avro schemas and Confluent® Schema Registry