[GitHub] [inlong] haifxu opened a new pull request, #7935: [INLONG-7934][Manager] Optimize the serializationType to support debezium json

[via GitHub]

haifxu opened a new pull request, #7935:
URL: https://github.com/apache/inlong/pull/7935

   - Fixes #7934 
   
   ### Motivation
   
   1. We need to use different data serialization types based on different data 
sources. For files, various formats such as CSV and JSON can be used, but for 
MySQL, PostgreSQL, etc., only debezium Json can be used, so it is placed in the 
`serializationType` of the stream source as a fixed value.
   
   ### Modifications
   
   1. Set the `serializationType` in `MQSource` according to the data source 
type.
   2. Set fixed value for source using debezium.
   
   ### Verifying this change
   
   
![image](https://user-images.githubusercontent.com/58519431/234782385-f898af81-ac47-4945-a828-4ac8729d6c75.png)
   
   
![image](https://user-images.githubusercontent.com/58519431/234782458-3293b75e-c6f2-41b8-8a0f-9f650cab21a0.png)
   


-- 
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