MQTTKafkaBridge

KO | EN

gitlite — search

#javascript #llm #go #machine-learning #deep-learning #linux #nodejs #java #windows #kubernetes #vue #mcp #openai #open-source

MQTTKafkaBridge

(★ 18)

Bridge MQTT Messages from Mosquitto to Kafka Broker on the same topic.

MQTTKafkaBridge 최신버젼 다운로드

최종 버전 다운로드 (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# MQTTKafkaBridge

Bridge which consumes MQTT messages and republishes them on Kafka on the same topic. Kafka does not support '/' as the topic name.

## Usage

$ java -jar Bridge.jar [options...]

Where `options` are:

--help (-h)  : Show help
    --id VAL     : MQTT Client ID
    --topics VAL : MQTT topic filters (comma-separated)
    --uri VAL    : MQTT Server URI
    --zk VAL     : Zookeeper connect string

If you don't specify any command-line options, it uses the following defaults:

id:      mqttKafkaBridge
    topics:  '#' (all topics)
    uri:     tcp://localhost:1883
    zk:      localhost:2181

***Note***: you can't run more than one bridge using the default settings, since two clients cannot connect to the same MQTT server with the same client ID. Additionally, you will get multiple messages published to Kafka for each message published to MQTT. If you wish to run multiple instances, you'll need to divide up the topics among the instances, and make sure to give them different IDs.

## Logging
`mqttKafkaBridge` uses [log4j](http://logging.apache.org/log4j/2.x/) for logging, as do the [Paho](http://www.eclipse.org/paho/) and [Kafka](http://kafka.apache.org/) libraries it uses. There is a default `log4j.properties` file packaged with the jar which simply prints all messages of level `INFO` or greater to the console. If you want to customize logging, simply create your own `log4j.properties` file, and start up `mqttKafkaBridge` as follows:

$ java -Dlog4j.configuration=file:///path/to/log4j.properties -jar mqttKafkaBridge.jar [options...]

## Binary
You can directly run the binary `Bridge.jar` which is available under Binary Folder. The binary build using Java Runtime 1.7.

MQTTKafkaBridge

MQTTKafkaBridge 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

MQTTKafkaBridge

MQTTKafkaBridge 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README