PeterZh6 opened a new pull request, #11554: URL: https://github.com/apache/inlong/pull/11554
Fixes #11495 Fixes #11553 ### Motivation To verify the correctness of #11494 in a formal way. To fix the problem of #11494, which is documented in #11553 ### Modifications For #11495, added end2end test for Kafka connector by producing kafka message with `kafka-clients` dependency and extract the information with Kafka connector introduced by #11494. To better automate the whole process, the result is loaded to Elasticsearch7 with the existing elsasticsearch7-inlong connector. The result is then retrieved by elasticsearch client dependency and compared with the expected result. For #11553, the package name in meta-inf of the Kafka connnector is corrected, so that the `DynamicFactory` class can work properly. ### Verifying this change - [ ] This change is a trivial rework/code cleanup without any test coverage. - [ ] This change is already covered by existing tests, such as: - [x] This change added tests and can be verified as follows: switch to `/inlong/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.18` directory and run `mvn clean test -Dtest=Kafka2Elasticsearch7Test` <img width="1280" alt="ES_end2end" src="https://github.com/user-attachments/assets/0bba08d3-2c95-4abd-9894-9090280cdeec";> ### Documentation - Does this pull request introduce a new feature? No - If yes, how is the feature documented? N/A - If a feature is not applicable for documentation, explain why? Test introduced. No need for documentation -- 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: commits-unsubscr...@inlong.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
