据我所知，kafkaconnect读取最后一个文件名的最新偏移量。如果文件已从目录中移出，它将如何跟踪最后读取的偏移量？
ldxq2e6h1#
这取决于哪个连接器接收器的独立模式（can）存储偏移文件。然而，在分布式模式下 connect-offsets 从中读取主题。不过，connect仍然维护一个使用者组id，因此如果文件丢失，协议仍然能够从最后提交的偏移量恢复。
connect-offsets
1条答案
按热度按时间ldxq2e6h1#
这取决于哪个连接器
接收器的独立模式（can）存储偏移文件。然而，在分布式模式下
connect-offsets从中读取主题。不过，connect仍然维护一个使用者组id，因此如果文件丢失，协议仍然能够从最后提交的偏移量恢复。