curcur commented on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-622262988
Hey, @AHeise and @pnowojski. Thanks so much for your time and efforts, really appreciate! I think this is a fair and practical workaround. My first intention was that "operator" is put with the API module, and function implementation is put with the Kafka connector module. But now since the operator is tailored specifically for new KafkaShuffleFunction, then it is no need to put the custom operator in the API module anymore. If I wrap everything in the `flink-connector-kafka`, I agree there should not be any cyclic dependency issue. I will do the updates, and thank you both again! ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
