You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
refer to the code current PartitionWriter read offsets from a fixed topic path: String path = FileUtils.topicDirectory(url, topicsDir, tp.topic());
the path comes to "url/topicsDir/topic"
if customed Partitioner.geratePartitionedPath do not return a path with that form, then the tp writer can not read the offset and will always start with offset 0...
Thanks.
The text was updated successfully, but these errors were encountered:
refer to the code current PartitionWriter read offsets from a fixed topic path:
String path = FileUtils.topicDirectory(url, topicsDir, tp.topic());
the path comes to "url/topicsDir/topic"
if customed Partitioner.geratePartitionedPath do not return a path with that form, then the tp writer can not read the offset and will always start with offset 0...
Thanks.
The text was updated successfully, but these errors were encountered: