有什么方法可以调整 Kafka Connect 中的消费者配置?
Is there any way to tweak consumer configurations in Kafka Connect?
我正在修改 memsql Kafka Connector 代码,Kafka connect 似乎不使用 Kafka 消费者订阅 API 所以我想知道是否有任何方法可以更改消费者的配置,例如组 ID、分区分配策略,...?
可以在工作人员级别覆盖消费者的配置:
consumer.auto.offset.reset=latest
或在连接器级别:
"consumer.override.auto.offset.reset": "latest"
我正在修改 memsql Kafka Connector 代码,Kafka connect 似乎不使用 Kafka 消费者订阅 API 所以我想知道是否有任何方法可以更改消费者的配置,例如组 ID、分区分配策略,...?
可以在工作人员级别覆盖消费者的配置:
consumer.auto.offset.reset=latest
或在连接器级别:
"consumer.override.auto.offset.reset": "latest"