Parameter | Description/Action | |
$topic | Specifies the topic name where the specified value overrides the configured value in the template. | |
$partition (optional) | Specifies the partition in which the message is stored. The specified value overrides the configured value in the template. | |
messages | Specifies a set of messages with key, value, and header to be published. | |
key | Specifies the key to denote the partition in which the messages are added. Messages with the same key are added to a single partition. | |
value | Specifies the unit of information that needs to be sent. | |
header | Specifies the list of key-value pairs to be added as header in the record. Note: This parameter appears when the Apache Kafka version of the producer connection is version 11 or later. | |
globalHeader | Specifies the list of key-value pairs to be added as header in the record if individual messages do not have headers. | |
Parameter | Description/Action | |
result | Specifies the metadata with the following fields of the corresponding message that has been published to Apache Kafka cluster. | |
isSuccess | Specifies whether the message is sent successfully or not. | |
topic | Specifies the topic in which the message is appended. | |
offset | Specifies the offset of the message in the Kafka topic or Kafka partition. | |
partition | Specifies the partition in which the messages are sent. | |
errorMessage | Specifies the error if the message delivery fails. | |