[jira] [Created] (FLINK-32273) What is org.apache.flink.avro.generated.record_json?

["Tan Kim (Jira)" <ji...@apache.org>]

Tan Kim created FLINK-32273:
-------------------------------

             Summary: What is org.apache.flink.avro.generated.record_json?
                 Key: FLINK-32273
                 URL: https://issues.apache.org/jira/browse/FLINK-32273
             Project: Flink
          Issue Type: Bug
          Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / API
            Reporter: Tan Kim


I'm trying to relay a topic from kafka to another kafka.

This is the original record in source topic.
{code:java}
"json": {
        "eventName": "event-ABC",
        ...
    } {code}
The source is json format and sink is avro format with confluent-schema registry.

Here is my code.

 
{code:java}
tableEnv.executeSql("CREATE TABLE source_table (..) WITH (
'connector'='kafka', 
'format'='json',
)")

tableEnv.executeSql("CREATE TABLE sink_table WITH (
'connector'='kafka',
'format'='avro-confluent',
..
)"){code}
If I run this code without 'value.avro-confluent.subject' configuration, the record is some like this.
{code:java}
{
    "json": {
        "org.apache.flink.avro.generated.record_json": {
            "eventName": {
                "string": "event-ABC"
            },
           ..
         }
}      {code}
I don't understand why flink-avro inserts "org.apache.flink.avro.generated.record_json" between `json` and `eventName`.

Also `eventName` is not just 'event-ABC' but `string: event-ABC`.

 

Is this bug? or something I missed?

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)