KafkaProducer

This block publish a message on a given MQTT topic.

    KafkaProducer

Parameters

KafkaProducer_0

NameLabelDescriptionData TypeValid 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

NameLabelDescriptionData TypeValid Values

log_file_name

Log file name (*.log)

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

String

Ports

NameTypeDescriptionIO TypeNumber

Port 1

explicit

input

nin

Port 2

activation

input

1