kafka

The kafka middleware sends messages to Kafka topics.

fnrunner Key

fnrun.middleware/kafka

Configuration

The following table describes the keys on the configuration object for the kafka middleware.

KeyTypeDefaultDescription
brokersString""A comma-delimited list of broker addresses
successTopicString""An optional topic for successful fn output
errorTopicString""An optional topic for errors returned from an fn
certFileString""The path to a certificate file required for a TLS connection
keyFileString""The path to a key file required for a TLS connection
caFileString""The path to a CA file required for a TLS connection
verifySSLBoolfalseIndicates whether the system should verify the SSL certificate chain

Examples

The following reads messages from test-topic and sends outputs and errors to success-topic and error-topic, respectively.

source:
  fnrun.source/kafka:
    brokers: 127.0.0.1:9092
    topics: test-topic
    ignoreErrors: true
    group: testGroup
middleware:
  - fnrun.middleware/key: value
  - fnrun.middleware/kafka:
      brokers: 127.0.0.1:9092
      successTopic: success-topic
      errorTopic: error-topic
fn: 
  fnrun.fn/cli: python3 ./app.py

Edit this page on GitHub