Jason Gustafson created KAFKA-4758:
--------------------------------------
Summary: Connect WorkerSinkTask is missing checks for NO_TIMESTAMP
Key: KAFKA-4758
URL: https://issues.apache.org/jira/browse/KAFKA-4758
Project: Kafka
Issue Type: Bug
Components: KafkaConnect
Reporter: Jason Gustafson
Assignee: Ryan P
The current check for NO_TIMESTAMP_TYPE is not sufficient. Upconverted messages
will have a timestamp type, but if the topic is set to use CREAT_TIME, the
timestamp will be NO_TIMESTAMP (-1). We should use {{null}} in that case.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)