我正在使用Kafka 0.10.0.1并希望在分布式模式下设置Kafka接收器 . 我在用户指南中注意到,消费者配置可以通过在前面添加“consumer”来覆盖,并且这些配置更改将应用于在该worker上运行的所有连接器 .

只是为了检查我的理解是否正确,我没有误解这一点 . 这意味着如果我想要使用不同的Kafka使用者属性运行多个连接器,例如auto.offset.reset,如果连接器在同一个工作器上运行,这将不可能实现?

或者是否可以为每个连接器设置consumer.auto.offset.reset属性并覆盖工作程序配置?