[KAFKA-4758] Connect WorkerSinkTask is missing checks for NO_TIMESTAMP

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.11.0.0
• Component/s: connect
• Assignee: Ryan P
• Reporter: Jason Gustafson
• Created: 11/Feb/17 19:39
• Updated: 13/Feb/17 00:07
• Resolved: 13/Feb/17 00:07

Description

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.

Issue Links

• links to: GitHub Pull Request #2533