Skip to content

Commit

Permalink
Merge pull request #563 from OpenFn/update-kafka-deployment
Browse files Browse the repository at this point in the history
Added local deployment note
  • Loading branch information
aleksa-krolls committed Sep 14, 2024
2 parents 44e3ef7 + 7b65ae8 commit 53dab0d
Showing 1 changed file with 13 additions and 5 deletions.
18 changes: 13 additions & 5 deletions docs/build/triggers.md
Original file line number Diff line number Diff line change
Expand Up @@ -98,6 +98,13 @@ published by a Kafka cluster. The triggers make use of Kafka consumer groups
that are set up on-demand to receive messages from a defined cluster then
converts them to `Input` dataclips that are used to initialize a Work Order.

:::info For self-hosted OpenFn deployments

Instance administrators have to enable Kafka for their instance by setting
`KAFKA_TRIGGERS_ENABLED=yes` in the environment variable.

:::

![Configuring Kafka Trigger](/img/configuring-kafka.png)

:::info What is Kafka?
Expand All @@ -111,17 +118,18 @@ more.

### Configuring a Kafka trigger for your workflow

1. Create a new Workflow or open an existing Workflow in your Project.
2. Select `Kafka Consumer` from the `Trigger type` dropdown.
1. Create a new Workflow or open an existing Workflow in your Project
2. Click on the workflow's Trigger and change the trigger type to
`Kafka Consumer` in the `Trigger type` dropdown.
3. Fill out the required connection details:

- **Hosts**: Provide the URL of the host(s) your trigger should listen to for
messages.
- **Topics**: Enter the topics your Kafka consumers should subscribe to. You
need at least one topic for a successful connection.
- **SSL**: Some Kafka clusters require an SSL connection. If you are connecting
to an environment that requires SSL connection, select `Enable SSL`.
- **SSL Authentication**: Select the type of authentication required for the
- **SSL**: Some Kafka clusters require SSL connection. If you are connecting to
an environment that requires SSL connection, select `Enable SSL`.
- **SSL Authentication**: Select the type of Authentication required for the
Kafka cluster.
- **Initial offset policy**: The intial offset dictates where the consumer
starts reading messages from a topic when it subscribes for the first time.
Expand Down

0 comments on commit 53dab0d

Please sign in to comment.