alexeykudinkin commented on code in PR #6270:
URL: https://github.com/apache/hudi/pull/6270#discussion_r969816288
##
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java:
##
@@ -311,7 +311,9 @@ private List
fetchPartitionInfos(KafkaConsumer
alexeykudinkin commented on code in PR #6270:
URL: https://github.com/apache/hudi/pull/6270#discussion_r947181371
##
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java:
##
@@ -311,7 +311,9 @@ private List
fetchPartitionInfos(KafkaConsumer