mqttBroker

string

The MQTT address.

Default: "tcp://localhost:1883"

mqttClientID

string

The client identifier.

Default: "mqttConsumer"

topic

string

The category name to which records are published.

Default: "testmqtt/test1"

numRetryAttempts

int

The number of attempts to retry.

Default: 0

retryPeriodInMs

int

The time period for each retry in milliseconds.

Default: 0

username

string

The MQTT optional username.

Default: ""

password

string

The MQTT optional password.

Default: ""

insecureSkipVerify

bool

Controls whether a client verifies the server's certificate chain and host name.

Default: false

tlsCertificateFile

string

The TLS certificate file path.

Default: ""

tlsKeyFile

string

The TLS key file path.

Default: ""

cleanSession

bool

Will set the "clean session" flag in the connect message.

Default: false

inmessage

message

The stream of records to publish.