KafkaEndpoint
topic
(string, required)
topic
(string, required)Any valid topic name addressing a single data-point
Example: "topic_name"
acks
(number, enum)
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)
timeout
(number)The time to await a response from the broker in milliseconds
Default: 30000
compression
(string, enum)
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)
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
Last updated