-
Notifications
You must be signed in to change notification settings - Fork 429
[BAHIR-212] Add MQTT Connector for Flink #100
base: master
Are you sure you want to change the base?
Conversation
@lresende @mbalassi @eskabetxe @gyfora Appreciate for your time to review this PR. thanks! |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks @yuruguo for the contribution :)
I have added a few comments.
} | ||
|
||
private boolean connect() throws Exception { | ||
this.serverUrl = properties.getProperty(MqttConfig.SERVER_URL); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why we need to save this values?
count be used directly where needed?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It's ok to use directly where needed, but this values may be used in multiple places, such as properties.getProperty(MqttConfig.SERVER_URL)
, so saving them separately can ensure the code is concise.
Properties mqttProperties = new Properties(); | ||
|
||
// mqtt server url = tcp://<Org_ID>.messaging.internetofthings.ibmcloud.com:1883 | ||
mqttProperties.setProperty(MqttConfig.SERVER_URL, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
could we use some docker image instead of a external system?
Java library to integrate MQTT protocol and Apache Flink.
Main goal is to be able to read/write data from/to MQTT using the Flink DataStream API.