This is an automated email from the ASF dual-hosted git repository. oalsafi pushed a commit to branch rearrange-date-time in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit f04f2f81133e56d8e32f38471f9fa876240b3c45 Author: Omar Al-Safi <omars...@gmail.com> AuthorDate: Tue Dec 17 17:23:30 2019 +0100 Add checkstyle profile and rename sub modules in poms --- .../java/org/apache/camel/kafkaconnector/CamelSourceTask.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java index 2c39f1e..6a31008 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java @@ -171,6 +171,10 @@ public class CamelSourceTask extends SourceTask { record.headers().addByte(keyCamelHeader, (byte)value); } else if (value instanceof Byte[]) { record.headers().addBytes(keyCamelHeader, (byte[])value); + } else if (value instanceof Time) { + record.headers().addTime(keyCamelHeader, (Time)value); + } else if (value instanceof Timestamp) { + record.headers().addTimestamp(keyCamelHeader, (Timestamp)value); } else if (value instanceof Date) { SimpleDateFormat sdf = new SimpleDateFormat("YYYY-MM-dd"); String convertedDate = sdf.format(value); @@ -187,11 +191,7 @@ public class CamelSourceTask extends SourceTask { record.headers().addLong(keyCamelHeader, (long)value); } else if (value instanceof Short) { record.headers().addShort(keyCamelHeader, (short)value); - } else if (value instanceof Time) { - record.headers().addTime(keyCamelHeader, (Time)value); - } else if (value instanceof Timestamp) { - record.headers().addTimestamp(keyCamelHeader, (Timestamp)value); - } + } } }