gosonzhang opened a new issue, #8252: URL: https://github.com/apache/inlong/issues/8252
### Description Current implementation: When the configured Topic cannot be found by groupId/streamId, the current implementation will select the default Topic on the Source side and forward it to the Sink side; after the Sink side receives the message, it will search for the Topic to be delivered according to the groupId/streamId again, if not If it exists, reject or discard the message Which needs to be adjusted: when the configured topic cannot be found in the groupId/streamId, the Source side passes the default Topic backward, and the Sink side still needs to obtain the default Topic again when the configured Topic cannot be found in the groupId/streamId. There are repeated operations; adjust them to be performed only on the Sink side, which facilitates the unification of Topic selection logic. ### InLong Component InLong DataProxy ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- 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]
