Details
Description
The following error message
org.apache.kafka.connect.errors.DataException: Invalid Java object for schema type INT64: class java.lang.Long for field: "moderate_time"
can be confusing because java.lang.Long is acceptable type for schema INT64. In fact, in this case org.apache.kafka.connect.data.Timestamp is used but this info is not logged.
Attachments
Issue Links
- links to