Kafka Consumer

Block Category: Extensions > IOT

Outputs:

      rdy: Indicates if a new message has arrived.

      val: The data in string format.

Description: Ths Kafka Consumer block reads messages from one or more Kafka topics. To use this block, make sure ZooKeeper and Apache Kafka are set up for use on your computer.

Group ID: Specifies the consumer group to which the Kafka Consumer instance belongs.

Host/Broker Name: Specifies the Kafka broker address.

Polling Time (in ms): Specifies the maximum time to wait for consumer messages or events. If no records are received before this time expires, Kafka Consumer block returns an empty record set.

Topic: Specifies the topic on which the message is to be stored.