apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: <name>
spec:
type: bindings.kafka
metadata:
- name: topics # Optional. in use for input bindings
value: topic1,topic2
- name: brokers
value: localhost:9092,localhost:9093
- name: consumerGroup
value: group1
- name: publishTopic # Optional. in use for output bindings
value: topic3
- name: authRequired # Required. default: "true"
value: "false"
- name: saslUsername # Optional.
value: "user"
- name: saslPassword # Optional.
value: "password"
topics
is a comma separated string of topics for an input binding.brokers
is a comma separated string of kafka brokers.consumerGroup
is a kafka consumer group to listen on.publishTopic
is the topic to publish for an output binding.authRequired
determines whether to use SASL authentication or not.saslUsername
is the SASL username for authentication. Only used ifauthRequired
is set to -"true"
.saslPassword
is the SASL password for authentication. Only used ifauthRequired
is set to -"true"
.
Note: In production never place passwords or secrets within Dapr components. For information on securly storing and retrieving secrets refer to Setup Secret Store