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.
☆26Updated 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☆57Updated 11 months ago
- mqtt (source) conncetor for kafka☆177Updated 8 years ago
- Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data☆210Updated 5 years ago
- This application receives messages from a mqtt broker and sends the messages to a kafka cluster. Topic mapping is configurable.☆29Updated 4 months ago
- ThingsBoard Community Edition Kubernetes scripts and docs☆79Updated last week
- datacollector-oss☆95Updated 8 months ago
- Connector to MQTT in Flink☆22Updated 4 years ago
- Java client for managing Apache Flink via REST API☆57Updated 3 months ago
- Deep Learning UDF for KSQL, the Streaming SQL Engine for Apache Kafka with Elasticsearch Sink Example☆78Updated 6 years ago
- Thingsboard performance tests☆45Updated last year
- Apache flink☆21Updated 11 months ago
- Cassandana :: MQTT Message Broker☆76Updated last year
- ☆124Updated last week
- Camel Kafka Connector allows you to use all Camel components as Kafka Connect connectors☆160Updated this week
- Apache MiNiFi (a subproject of Apache NiFi)☆125Updated 4 years ago
- Grok Expression Transform for Kafka Connect.☆16Updated 4 years ago
- Instructions for getting started with Ververica Platform on minikube.☆91Updated 3 months ago
- sql 血缘解析（hive sql、spark sql、starrocks sql、doris sql）☆21Updated 2 years ago
- Flink Controller implements a Kubernetes Custom Controller (aka Kubernetes Operator) for Apache Flink☆53Updated 4 months ago
- Aiven's JDBC Sink and Source Connectors for Apache Kafka®☆104Updated 3 weeks ago
- MQTT on Pulsar implemented using Pulsar Protocol Handler☆179Updated this week
- Apache flink☆148Updated this week
- Watson IoT Platform Connector for Apache Flink☆14Updated 5 years ago
- CDC Kafka Connect source for Oracle Databases leveraging Oracle Logminer☆32Updated last week
- One Click Script to Deploy CDP (CDP PvC & HDP & CDH)☆31Updated 3 weeks ago
- 此项目主要应用于数据中台或数据平台的数据总线，支持直接实时监听MySQL、MongoDB、PostgreSQL、Oracle、SQL Server、Db2和Cassandra等数据库的数据变更。☆62Updated last year
- Kafka Connect Elasticsearch Source☆66Updated 8 months ago
- Apache StreamPark quickstart☆71Updated 2 months ago
- InfluxDB Processors For Apache NiFi☆37Updated 8 months ago
- NiFi Processor for Apache Pulsar☆18Updated 5 months ago