SINTEF-9012 / kafka-mqtt-source-connector
A connector plugin to use with Kafka's Connect API. It can be configured to map any topic from an mqtt broker to any topic on the Kafka broker. The connector can be configured to use SSL in communication with the mqtt broker.
☆24Updated 3 years ago
Alternatives and similar repositories for kafka-mqtt-source-connector:
Users that are interested in kafka-mqtt-source-connector are comparing it to the libraries listed below
- Kafka Connect MQTT Connector☆56Updated 8 months ago
- mqtt (source) conncetor for kafka☆178Updated 8 years ago
- Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data☆209Updated 4 years ago
- This application receives messages from a mqtt broker and sends the messages to a kafka cluster. Topic mapping is configurable.☆28Updated last month
- Apache flink☆19Updated 8 months ago
- Grok Expression Transform for Kafka Connect.☆16Updated 4 years ago
- datacollector-oss☆91Updated 6 months ago
- Connector to MQTT in Flink☆22Updated 4 years ago
- Flink Controller implements a Kubernetes Custom Controller (aka Kubernetes Operator) for Apache Flink☆53Updated last month
- CDC Kafka Connect source for Oracle Databases leveraging Oracle Logminer☆32Updated this week
- MQTT on Pulsar implemented using Pulsar Protocol Handler☆176Updated this week
- Omron FINS Protocol☆12Updated 8 years ago
- Camel Kafka Connector allows you to use all Camel components as Kafka Connect connectors☆158Updated this week
- Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data strea…☆625Updated this week
- flink iceberg integration tests, jobs running on yarn.☆38Updated 3 years ago
- Instructions for getting started with Ververica Platform on minikube.☆91Updated 3 weeks ago
- InfluxDB Processors For Apache NiFi☆40Updated 6 months ago
- This Apache Atlas is built from the latest release source tarball and patched to be run in a Docker container.☆138Updated last year
- Apache flink☆46Updated last week
- ☆32Updated 6 years ago
- Apache flink☆142Updated this week
- Apache StreamPark quickstart☆68Updated 2 weeks ago
- A kafka-connect REST api client for java☆40Updated 4 months ago
- InfluxDB 2 Connector for Kafka☆13Updated 4 years ago
- HiveMQ extension for transferring monitoring data to Prometheus☆20Updated this week
- Kafka Connect connector that enables Change Data Capture from JSON/HTTP APIs into Kafka.☆126Updated 5 months ago
- ☆11Updated 7 months ago
- Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.☆206Updated this week
- Move your messages from MQTT to Apache Kafka in real-time☆40Updated 2 years ago
- Real Time Big Data / IoT Machine Learning (Model Training and Inference) with HiveMQ (MQTT), TensorFlow IO and Apache Kafka - no addition…☆411Updated 4 years ago