Kafka MQTT Source

Simple app to collect messages from MQTT broker (Mosquitto) and send it to Apache Kafka

Requirements

• Golang 1.17 or more
• make (linux)

Build with Makefile

• Show the make help: make help
• Build the binary: make build
• The binary will be available at out/bin directory.
• Build docker image: make build-docker-image

Configure main.go

Run using go command

• go mod download
• go run cmd/main.go

Show help

me-mqtt-source --help