Skip to main content

Kafka

The kafka trigger publishes container update event messages to an Apache Kafka topic for stream processing.

⚙️ Configuration Variables​

WUD_TRIGGER_KAFKA_{trigger_name}_BROKERS
Requiredstring

Comma-separated list of Kafka broker bootstrap endpoints

Allowed values:Comma-separated `host:port` pairs
WUD_TRIGGER_KAFKA_{trigger_name}_AUTHENTICATION_PASSWORD
Optionalstring

SASL password (required when authentication is enabled)

WUD_TRIGGER_KAFKA_{trigger_name}_AUTHENTICATION_TYPE
Optionalenumdefault: PLAIN

SASL authentication mechanism

Allowed values:`PLAIN`, `SCRAM-SHA-256`, `SCRAM-SHA-512`
WUD_TRIGGER_KAFKA_{trigger_name}_AUTHENTICATION_USER
Optionalstring

SASL username (required when authentication is enabled)

WUD_TRIGGER_KAFKA_{trigger_name}_SSL
Optionalbooleandefault: false

Enable TLS/SSL encryption for broker connections

WUD_TRIGGER_KAFKA_{trigger_name}_TOPIC
Optionalstringdefault: wud-container

Kafka topic name to publish records to

Topic Pre-creation Required

The destination Kafka topic must already exist on your cluster; WUD will not create missing topics automatically.

info

This trigger also supports all common trigger configuration options (such as thresholds, scheduling, and batching).

🚀 Examples​

Publish Events to a Secured Kafka Cluster​

services:
  whatsupdocker:
    image: getwud/wud
    environment:
      - WUD_TRIGGER_KAFKA_LOCAL_BROKERS=kafka-1.example.com:9094,kafka-2.example.com:9094
      - WUD_TRIGGER_KAFKA_LOCAL_SSL=true
      - WUD_TRIGGER_KAFKA_LOCAL_TOPIC=wud-container-updates
      - WUD_TRIGGER_KAFKA_LOCAL_AUTHENTICATION_USER=wud-publisher
      - WUD_TRIGGER_KAFKA_LOCAL_AUTHENTICATION_PASSWORD=your_sasl_secret
      - WUD_TRIGGER_KAFKA_LOCAL_AUTHENTICATION_TYPE=SCRAM-SHA-256