我有一个问题,我的Kafka Connect worker配置在节点重启后丢失。(http://broker:port/connectors/ ->空数组)
现在我认为这可能与"retention.ms“配置有关。因为连接配置也存储在"config.storage.topic“中,并且在"retention.ms”之后将被删除?所以我必须设置一个非常高的"retention.ms“。这是正确的还是由Kafka自动管理的?(以防您自己创建主题)
其他两个主题如何: status.storage.topic -仅当前状态信息,不那么重要?offset.storage.topic
https://stackoverflow.com/questions/41608702
复制相似问题