我创建了一个将数据转换为其他存储的接收器kafka connect;当使用 kafka connect rest api 创建新连接器时，我想将 auto.offset.reset 设置为 latest ;我在配置中设置了 consumer.auto.offset.reset: latest ;
json { "name": "test_v14", "config": { "name": "test_v14", "consumer.auto.offset.reset": "latest", "connector.class": "...", ... } }
但是当任务开始时， Kafka 消费者仍然从最早开始记录;那么将 auto.offset.reset 设置为最新的任何其他方法也是如此;
1 回答
consumer.auto.offset.reset需要在connect-distributed*.properties文件（Worker）中设置 .它不能应用于任何特定的连接器 .