mirror of https://github.com/dapr/docs.git
1.3 KiB
1.3 KiB
Kafka Binding Spec
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"
topicsis a comma separated string of topics for an input binding.brokersis a comma separated string of kafka brokers.consumerGroupis a kafka consumer group to listen on.publishTopicis the topic to publish for an output binding.authRequireddetermines whether to use SASL authentication or not.saslUsernameis the SASL username for authentication. Only used ifauthRequiredis set to -"true".saslPasswordis the SASL password for authentication. Only used ifauthRequiredis 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