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
- Thingsboard performance tests☆44Updated 10 months ago
- Grok Expression Transform for Kafka Connect.☆16Updated 3 years ago
- Apache flink☆19Updated 8 months ago
- Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data☆293Updated last year
- Deep Learning UDF for KSQL, the Streaming SQL Engine for Apache Kafka with Elasticsearch Sink Example☆78Updated 6 years ago
- Connector to MQTT in Flink☆22Updated 4 years ago
- datacollector-oss☆91Updated 5 months ago
- InfluxDB Processors For Apache NiFi☆40Updated 5 months ago
- CDC Kafka Connect source for Oracle Databases leveraging Oracle Logminer☆32Updated this week
- A kafka-connect REST api client for java☆40Updated 3 months ago
- Kafka Connect Elasticsearch Source☆66Updated 5 months ago
- Camel Kafka Connector allows you to use all Camel components as Kafka Connect connectors☆156Updated this week
- InfluxDB 2 Connector for Kafka☆13Updated 4 years ago
- Kafka Connect connector that enables Change Data Capture from JSON/HTTP APIs into Kafka.☆126Updated 5 months ago
- MQTT on Pulsar implemented using Pulsar Protocol Handler☆176Updated last week
- Kettle plugins for Apache Beam☆42Updated 2 years ago
- OpenSCADA Atlantis☆29Updated 7 years ago
- ☆80Updated last year
- 🚀 Azkarra is a lightweight java framework to make it easy to develop, deploy and manage cloud-native streaming microservices based on Ap…☆183Updated 2 years ago
- Kafka Connect Transform to copy Avro schemas between Schema Registries☆57Updated last year
- Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data strea…☆622Updated this week
- ☆112Updated this week
- Java client for managing Apache Flink via REST API☆56Updated 3 weeks ago
- Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data strea…☆26Updated 2 years ago
- Flink Controller implements a Kubernetes Custom Controller (aka Kubernetes Operator) for Apache Flink☆53Updated last month
- ☆32Updated 6 years ago