kafka-cdc-sink: Missing name field in debezium json

[xuefengze]

According to debezium data type mapping, semantic type(aka. name) describes how the Kafka Connect schema captures the meaning of the field using the name of the Kafka Connect schema for the field.

Example:
In the Risingwave -(Debezium Json)-> Kafka -(Debezium Json)-> JDBC connector -> PostgreSQL pipeline of our implementation, the DATE type in the message event appears like this:

{
  "field": "c_date",
  "optional": true,
  "type": "int32"
}

Well in Debezium PG connector, it appears like this:

{
  "field": "c_date",
  "optional": true,
  "type": "int32",
  "name": "io.debezium.time.Date"
}

If we use debezium jdbc connector, it can automatically convert c_date type to DATE by name. Currently, we are only seeing the c_date type as an integer in PostgreSQL. And we need additional configuration in the JDBC connector to parse c_date, so that we can see the DATE type in PostgreSQL.

[fuyufjh]

I am confused by the issue description? 👀

Missing name field in debezium json

So are you proposing to add the name field in the output of kafka debezium sink, right?