kafka

Latest Version	v1.0.0
Input Content Type	Any

Incurs Usage

Sending data to Kafka incurs usage costs after exceeding the free tier. See Golioth pricing for more information.

The kafka destination sends data to a Kafka cluster.

Parameters

Parameter	Type	Description	Required
brokers	[]string	List of broker addresses.	✅
topic	string	The name of the Kafka topic.	✅
username	string	The username for authentication.	✅
password	string	The password for authentication.	✅
sasl_mechanism	string	The SASL authentication mechanism. Valid options include PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.	✅

info

SASL_SSL is always enabled, regardless of sasl_mechanism selected.

Example Usage

    destination:
      type: kafka
      version: v1
      parameters:
        brokers:
          - my.kafka.broker.com:9092
        topic: my-topic
        username: pipelines-user
        password: $KAKFA_PASSWORD
        sasl_mechanism: PLAIN

Example Input

{
  "temp": 32
}

Example Output

Output data will match input data exactly, regardless of content type. Message metadata will be encoded in event metadata headers.

{
  "temp": 32
}