[jira] [Created] (FLINK-20825) Upsert-kafka should throw a better exception when the key of the record is NULL

[Shengkai Fang (Jira)]

Shengkai Fang created FLINK-20825:
-------------------------------------

             Summary: Upsert-kafka should throw a better exception when the key 
of the record is NULL
                 Key: FLINK-20825
                 URL: https://issues.apache.org/jira/browse/FLINK-20825
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Kafka, Table SQL / API
    Affects Versions: 1.12.0
            Reporter: Shengkai Fang


Currently, it will get NPE when reading from the upsert-kafka with record whose 
key is NULL. 
The records in the compacted topic always have keys. Therefore, it's mainly 
wrong usage of the upsert-kafka that causing NPE. We can throw a better 
exception to notify the users.



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