[jira] [Created] (FLINK-24494) Avro conluent Resigry SQL not fails to write to the topic with schema with default value for int

["Mahendran Ponnusamy (Jira)" <ji...@apache.org>]

Mahendran Ponnusamy created FLINK-24494:
-------------------------------------------

             Summary: Avro conluent Resigry SQL not fails to write to the topic with schema with default value for int
                 Key: FLINK-24494
                 URL: https://issues.apache.org/jira/browse/FLINK-24494
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / API
    Affects Versions: 1.13.2
            Reporter: Mahendran Ponnusamy
         Attachments: KafkaTableTumbling.java

 

Given a schema registered to a topic with default value as '0' for int,

when the flink sql with upsert-kafka connector writes to the topic,

it fails coz the schema registered is not compatible with the data [schema] it is producing where there is not default value [{color:#9876aa}"default" {color}{color:#cc7832}: {color}{color:#6897bb}0{color}] for the int.

{color:#cc7832} {color}

{
 {color:#9876aa}"type" {color}{color:#cc7832}: {color}{color:#6a8759}"record"{color}{color:#cc7832},
{color} {color:#9876aa}"name" {color}{color:#cc7832}: {color}{color:#6a8759}"SimpleCustomer"{color}{color:#cc7832},
{color} {color:#9876aa}"namespace" {color}{color:#cc7832}: {color}{color:#6a8759}"com.nordstrom.nap.onehop.example.model"{color}{color:#cc7832},
{color} {color:#9876aa}"fields" {color}{color:#cc7832}: {color}[ {
 {color:#9876aa}"name" {color}{color:#cc7832}: {color}{color:#6a8759}"customerId"{color}{color:#cc7832},
{color} {color:#9876aa}"type" {color}{color:#cc7832}: {color}{color:#6a8759}"string"
{color} }{color:#cc7832}, {color}{
 {color:#9876aa}"name" {color}{color:#cc7832}: {color}{color:#6a8759}"age"{color}{color:#cc7832},
{color} {color:#9876aa}"type" {color}{color:#cc7832}: {color}{color:#6a8759}"int"{color}{color:#cc7832},
{color} {color:#9876aa}"default" {color}{color:#cc7832}: {color}{color:#6897bb}0
{color} } ][^KafkaTableTumbling.java]
}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)