我们正在使用Storm与Kafka和ZooKeeper.我们遇到了一种情况,我们不得不删除一些主题并用不同的名称重新创建它们.除了从新主题名称中读取之外,我们的卡夫卡鲸鱼喷水保持不变.但是现在,当尝试从新主题中读取时,spouts正在使用旧主题分区的偏移量.因此,my-topic-name分区0的尾部位置将为500,但偏移量将为10000.
有没有办法重置偏移位置,以便它匹配主题的尾部?
java apache-kafka apache-storm apache-zookeeper
apache-kafka ×1
apache-storm ×1
apache-zookeeper ×1
java ×1