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

Last updated

Logo

© Copyright 2024, Cybus GmbH