New message in topic trigger

Use this trigger to listen to new messages that are created in your Confluent Cloud topic. This trigger checks for new messages once every poll interval and Workato processes each message as a separate job.

Input fields

Field	Description
Trigger poll interval	Determine how frequently to check for new events. This defaults to five minutes if left blank. The minimum value allowed is five minutes.
Topic	Select a topic from the list or enter the topic name.
Message schema source	Select where your message schema is defined from either your common data models or your schema registry in Confluent Cloud. To retrieve schemas from your schema registry, you must configure your Confluent Cloud connection with your Stream Governance API credentials.
Message schema	Select a message schema from your common data models or schema registry.
Initial offset	Determine the initial offset. This value tells Workato how to handle the operation when there is no initial offset in Kafka or if the current offset no longer exists on the server. If set to Earliest, Workato starts fetching messages from the oldest available message in the topic. If set to Latest, Workato starts fetching messages from the most recent message. This value defaults to Earliest.

Output fields

The output datatree contains information about the message. This includes the key, raw message, partition, offset, timestamp, and size.

Field	Description
Key	The message key. This value is stored with the message.
Message	The message content.
Raw message	The raw message content.
Partition	The partition number.
Offset	The offset number.
Timestamp	The timestamp of the message.
Size	The size of the message in bytes.