dongwoo kim

Hello @morazow I've added ITCase for this case. This case fails for current main branch due to timeout and works okay with fixed code.

Thanks for confirming @morazow, Please feel free to provide any additional advice before merging this fix. It would be also helpful if you could elaborate more on the issue you...

Hello @morazow, I've added [test code](https://github.com/apache/flink-connector-kafka/blob/f3c9666caa0ef1577402a5c16d57664bf06f51ef/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java#L194) for the mentioned issue, please take a look. Test passes with this fixed code and on the latest main branch, it timeouts due to...

@AHeise thanks for the feedback! I've addressed your comments and applied the suggested changes. When you have a moment, please take a look. Thanks

> Seems like the deleted arch unit rule was still needed. What was your intent when you deleted it? It was automatically deleted after running `mvn clean verify` locally. I...

@AHeise Thanks for the feedback. I've left some comments and made updates. Please have a look.