[FLINK-36858][pipeline-connector][kafka] Fix compatibility with Flink 1.20 JsonRowDataSerializationSchema

[MOBIN-F]

pipeline.yml

source:
  type: mysql
  name: MySQL Source
  hostname: localhost
  port: 3306
  username: test
  password: test
  tables: testDB.testTable
  server-id: 5206
  server-time-zone: Asia/Shanghai
  
sink:
  type: kafka
  name: Kafka Sink
  properties.bootstrap.servers: localhost:9092
  topic: test_topic
pipeline:
  name: MySQL to Kafka Pipeline
  parallelism: 1 

Caused by: java.lang.NoSuchMethodError: 'void org.apache.flink.formats.json.JsonRowDataSerializationSchema.<init>(org.apache.flink.table.types.logical.RowType, org.apache.flink.formats.common.TimestampFormat, org.apache.flink.formats.json.JsonFormatOptions$MapNullKeyMode, java.lang.String, boolean)'
        at org.apache.flink.cdc.connectors.kafka.serialization.JsonSerializationSchema.buildSerializationForPrimaryKey(JsonSerializationSchema.java:134)
        at org.apache.flink.cdc.connectors.kafka.serialization.JsonSerializationSchema.serialize(JsonSerializationSchema.java:101)
        at org.apache.flink.cdc.connectors.kafka.serialization.JsonSerializationSchema.serialize(JsonSerializationSchema.java:47)
        at org.apache.flink.cdc.connectors.kafka.sink.PipelineKafkaRecordSerializationSchema.serialize(PipelineKafkaRecordSerializationSchema.java:99)
        at org.apache.flink.cdc.connectors.kafka.sink.PipelineKafkaRecordSerializationSchema.serialize(PipelineKafkaRecordSerializationSchema.java:44) 

In flink>=1.20, the constructor of JsonRowDataSerializationSchema has 6 parameters, and in flink<1.20, the constructor of JsonRowDataSerializationSchema has 5 parameters.

[MOBIN-F]

@lvyanquan @yuxiqian cc~

[lvyanquan]

Thanks for this contribution, left some minor comments.

[lvyanquan]

LGTM.

[lvyanquan]

Hi @leonardBang @ruanhang1993 could you please help to trigger the CI?

[MOBIN-F]

@leonardBang please help trigger ci when you have time, thank~