[jira] [Created] (FLINK-24977) validatePKConstraints in KafkaDynamicTableFactory throws wrong exception message

[Jingsong Lee (Jira)]

Jingsong Lee created FLINK-24977:
------------------------------------

             Summary: validatePKConstraints in KafkaDynamicTableFactory throws 
wrong exception message
                 Key: FLINK-24977
                 URL: https://issues.apache.org/jira/browse/FLINK-24977
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
            Reporter: Jingsong Lee


options.get(VALUE_FORMAT) should be 

configuration.get(VALUE_FORMAT)



--
This message was sent by Atlassian Jira
(v8.20.1#820001)