Working principle of Streaming modules

A Streaming topology can be developed and compressed into a JAR file by using Storm APIs or referring to the CQL syntax manual. After the topology is submitted to the Streaming cluster, Nimbus automatically assigns it to the Supervisor node for processing. The topology logs can be viewed on the UI through the port provided by Logviewer.

Scroll to top