Kafka 参数说明

Kafka 事件源参数说明

KafkaSpec

从属 EventSourceSpec

EventSource 会根据 KafkaSpec 生成用于适配 Kafka 事件源的 Dapr Bindings Components ，原则上我们会尽量维持相关参数的一致性。你可以通过访问 Kafka binding spec 获取更多信息。

字段描述
brokers string以逗号分隔的 Kafka 服务器地址的字符串。如：localhost:9092
authRequired bool是否启用 Kafka 服务器的 SASL 认证。可选：true， false
topic stringKafka 事件源的 topic 名称，如：topicA，myTopic
saslUsername string（可选） 用于认证的 SASL 用户名。只有在 authRequired 为 true 时才需要设置。如：admin
saslPassword string（可选） 用于认证的 SASL 用户密码。只有在 authRequired 为 true 时才需要设置。如：123456
maxMessageBytes int64（可选） 单个消息允许包含的最大字节数。默认为 1024。如：2048
scaleOption KafkaScaleOption（可选） Kafka 的自动伸缩选项

KafkaScaleOption

从属 KafkaSpec

字段描述
GenericScaleOption通用的自动伸缩配置
consumerGroup stringKafka 的 consumer group 名称
topic string伸缩器监控的 topic 名称，如：topicA, myTopic
lagThreshold string伸缩器的触发阈值，此处为 Kafka 的消息延迟量