All, See [1] for the code for the Edgent based Smart Camera device that was presented in the ApacheCon 2017 talk: Video Analytics at the Edge: Fun with Apache Edgent, OpenCV and a Raspberry Pi.
The Edgent application / smart device can connect to a general MQTT broker such as Apache ActiveMQ or IBM Watson IoT Platform. With a small change the device could connect to Apache Kafka. [1] https://github.com/IBMStreams/streamsx.edgevideoanalytics.starterkit <https://github.com/IBMStreams/streamsx.edgevideoanalytics.starterkit>
