KafkaEndpoint

topic (string, required)

Any valid topic name addressing a single data-point

Example: "topic_name"

acks (number, enum)

Control the number of required acknowledgements. -1 = all insync replicas must acknowledge (default); 0 = no acknowledgments; 1 = only waits for the leader to acknowledge

This element must be one of the following enum values:

• -1

• 0

• 1

Default: -1

timeout (number)

The time to await a response from the broker in milliseconds

Default: 30000

compression (string, enum)

The compression codec used to compress the messages

This element must be one of the following enum values:

• None

• GZIP

Default: "None"

fromBeginning (boolean)

Only for subscribe: Where to let the consumer start consuming messages. If true, start from the beginning of the topic. If false, start at the end.

Default: false