Efrat Levitan created FLINK-38869:
-------------------------------------

             Summary: InitializationContext for KafkaSubscriber
                 Key: FLINK-38869
                 URL: https://issues.apache.org/jira/browse/FLINK-38869
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Kafka
    Affects Versions: kafka-4.0.1
            Reporter: Efrat Levitan


Allow 
`org.apache.flink.connector.kafka.source.enumerator.subscriber.KafkaSubscriber` 
to be passed an initialization context via an `open(InitializationContext 
initializationContext)` lifecycle method, and a counterpart `close()`,
To be able to configure it later with KafkaSourceEnumerator level properties.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to