mas-chen commented on code in PR #44:
URL:
https://github.com/apache/flink-connector-kafka/pull/44#discussion_r1446686787
##########
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java:
##########
@@ -42,7 +42,7 @@ public KafkaSourceEnumState(
this.initialDiscoveryFinished = initialDiscoveryFinished;
}
- KafkaSourceEnumState(
+ public KafkaSourceEnumState(
Review Comment:
This is the only KafkaSource code that I had to modify. As a result of
moving packages, this needed to be publicly visible (the class is still
annotated as Internal)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
