Basic Information

appmixer.kafka.platform.SendMessage

1.0.0

Public

Publish a message.

Input Ports

in

FieldTypeDescription
Topic text Enter a topic.
Value textarea Enter a value.
Key text Enter a key. It is used to decide which partition the message will be sent to. For example, if you use an orderId as the key, you can ensure that all messages regarding that order will be processed in order.
Acks select Control the number of required acks.
Timeout number The time to await a response in ms.
Partition number Which partition to send the message to. If no partition is specified but a key is present choose a partition based on a hash (murmur2) of the key. If no partition or key is present choose a partition in a round-robin fashion.
Timestamp date-time The timestamp of when the message was created. UTC timestamp with millisecond precision.
Headers textarea Metadata to associate with your message in a JSON format.

Output Ports

out

FieldTypeDescription
Key -
Value -
Topic -

Full Metadata