Hello dear Flink community,
I made a small improvement in Flink’s Kafka Source and would appreciate communities feedback on it if it makes sense. Idea is to let users of the KafkaSource pass their own KafkaConsumerFactory that controls the creation of KafkaConsumer instances. JIRA: https://issues.apache.org/jira/browse/FLINK-36817 PR: https://github.com/apache/flink-connector-kafka/pull/137 Best, Levani
