KafkaProducer

This block publish a message on a given MQTT topic.

KafkaProducer

Library

Communicate

KafkaProducer_0

Name	Label	Description	Data Type	Valid Values
nin	Number of Inputs	Defines the number of inputs	Number
hostname	Hostname	Defines the hostname (broker's) IP address	String
topic	Topic	Defines the topic where the message will be published.	String
message	Message template	Defines the message to be published. This message can be of any format (text, JSON, ...). User can use %%1, %%2, ..., %%n to identify the inputs.	String
onFailure	Do on failure	Defines the behavior on failure.	Structure
onFailure/error	Error		Number	0 1
onFailure/warning	Warning		Number	0 1
onFailure/nothing	Nothing		Number	0 1

KafkaProducer_1

Name	Label	Description	Data Type	Valid Values
log_file_name	Log file name (*.log)	Messages are logged into this file. the filename can be 'stderr' or 'stdout'.	String

Name

Label

Description

Data Type

Valid Values

log_file_name

Log file name (*.log)

Messages are logged into this file. the filename can be 'stderr' or 'stdout'.

String

Name	Type	Description	IO Type	Number
Port 1	explicit		input	nin
Port 2	activation		input	1