It may be the case that offset is at the latest position. You can try seek from beginning. HashSet<TopicPartition> partitions = new ...
確定! 回上一頁