Google Git
Sign in
apache / pekko-connectors-samples / 0e83f31e8b8d90c53d22255fa1579a49a754e46d / . / pekko-connectors-sample-mqtt-http-to-s3-java
tree: 6a1d97c2f2202ee46d8423480ed9642ad21ef481 [path history] [tgz]
  1. project/
  2. src/
  3. .gitignore
  4. build.sbt
  5. docker-compose.yml
  6. README.md
pekko-connectors-sample-mqtt-http-to-s3-java/README.md

Apache Pekko Connectors sample

Listen to a MQTT topic, download from URL passed in received message, and upload data from that address to AWS S3

Running this requires:

  • MQTT broker running (provided via docker-compose)
  • AWS S3 account configured in ./src/main/resources/credentials.conf as exemplified in credentials.conf-RENAME
  • AWS bucket “pekko.connectors.samples” created

Messages to MQTT can be published by PublishDataToMqtt.