Argo Workflows · Schema

github.com.argoproj.argo_events.pkg.apis.events.v1alpha1.KafkaTrigger

KafkaTrigger refers to the specification of the Kafka trigger.

CNCFContainersData ProcessingKubernetesMachine LearningOpen SourceWorkflow Engine

Properties

Name Type Description
compress boolean
flushFrequency integer
headers object
parameters array Parameters is the list of parameters that is applied to resolved Kafka trigger object.
partition integer
partitioningKey string The partitioning key for the messages put on the Kafka topic. +optional.
payload array Payload is the list of key-value extracted from an event payload to construct the request payload.
requiredAcks integer RequiredAcks used in producer to tell the broker how many replica acknowledgements Defaults to 1 (Only wait for the leader to ack). +optional.
sasl object
schemaRegistry object
secureHeaders array
tls object
topic string
url string URL of the Kafka broker, multiple URLs separated by comma.
version string
View JSON Schema on GitHub