kafka connect:kafka connect如何读取最新的偏移量?

q8l4jmvw  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(498)

据我所知,kafkaconnect读取最后一个文件名的最新偏移量。
如果文件已从目录中移出,它将如何跟踪最后读取的偏移量?

ldxq2e6h

ldxq2e6h1#

这取决于哪个连接器
接收器的独立模式(can)存储偏移文件。然而,在分布式模式下 connect-offsets 从中读取主题。
不过,connect仍然维护一个使用者组id,因此如果文件丢失,协议仍然能够从最后提交的偏移量恢复。

相关问题