syhily commented on code in PR #20584:
URL: https://github.com/apache/flink/pull/20584#discussion_r981986456
##########
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range/RangeGenerator.java:
##########
@@ -51,7 +51,18 @@ public interface RangeGenerator extends Serializable {
*/
List<TopicRange> range(TopicMetadata metadata, int parallelism);
- /** Initialize some extra resource when bootstrap the source. */
+ /**
+ * Defines the default behavior for Key_Shared subscription in Flink. See
{@link KeySharedMode}
+ * for the detailed usage of the key share mode.
+ *
+ * @param metadata The metadata of the topic.
+ * @param parallelism The reader size for this topic.
+ */
+ default KeySharedMode keyShareMode(TopicMetadata metadata, int
parallelism) {
Review Comment:
This is kept only for end-user if they needs.
--
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
