apache-kafka - 如何在 Dapr 中设置 Kafka 生产者属性？

Question

在 Dapr 中将其用作发布/订阅组件时，是否可以设置 Kafka 生产者/消费者属性？更具体地说，我想设置 和 的compression.type值batch.size。

例如，Confluent Go 客户端允许您执行以下操作：

import "github.com/confluentinc/confluent-kafka-go/kafka"

p, err := kafka.NewProducer(&kafka.ConfigMap{
    "bootstrap.servers": "host1:9092,host2:9092",
    "client.id": socket.gethostname(),
    "acks": "all",
    "batch.size": "32000",
    "compression.type": "gzip",
})

你能在 Dapr 中做类似的事情吗？

我知道发布/订阅配置中的元数据字段。但是，在我的情况下，这些太有限了。