【发布时间】:2017-01-31 00:14:18
【问题描述】:
对于使用 KafkaAvroDeserializer 的 Kafka 流(消费者),我需要在部署时使用 --propertiesFile 覆盖一些配置才能工作。 KafkaBinder 1.1.1 添加了这个配置选项。
如果可以,我宁愿不使用部署属性,因为它们在仪表板上不可见,而且如果另一个用户决定停止并重新启动流而不设置属性,这很危险。是否可以在流定义中包含这些属性?我的多次尝试都失败了。我在参考文档中没有看到这样的示例。
例如对于 yaml 等效项:
<...>
binder:
configuration:
value.deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
schema.registry.url: http://my.dns.com:8081
【问题讨论】: