调用org.apache.zookeeper.server.quorum.QuorumPeerMain.main()不起作用.
java unit-testing apache-zookeeper
我正在使用zookeeper从kafka获取数据.在这里,我总是从最后一个偏移点获取数据.有没有办法指定偏移时间来获取旧数据?
有一个选项autooffset.reset.它接受最小或最大.有人可以解释什么是最小和最大的.autooffset.reset可以帮助从旧的偏移点而不是最新的偏移点获取数据吗?
offset apache-kafka apache-zookeeper zookeeper
apache-zookeeper ×2
apache-kafka ×1
java ×1
offset ×1
unit-testing ×1
zookeeper ×1