mas-chen opened a new pull request, #44: URL: https://github.com/apache/flink-connector-kafka/pull/44
…ed/unbounded support and unit/integration tests ### What is the purpose of the change [FLIP-246](https://cwiki.apache.org/confluence/x/CBn1D) describes the changes and this PR follows the design illustrated in the doc. ### Brief Change Log * New Public API: DynamicKafkaSource, DynamicKafkaSourceBuilder, KafkaMetadataService and related classes, etc. * Supports multi cluster read, dynamic cluster/topic read * Supports multi cluster, dynamic metrics * Supports StoppableKafkaEnumContextProxy to workaround and provide single threaded guarantees * Supports unbounded and bounded mode * Only supports configurations/deserializers defined uniformly across clusters, can be extended later on * 3 stream subscription methods * 1 KafkaMetadataService that supports single cluster, can expose more implementations in public API depending on discussion * Supports metadata discovery interval as well as error handling strategy ### Verifying this change * Unit Tests * Integration Tests (including covering migration scenarios) * Connector Test Framework Integration -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
