You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by oa...@apache.org on 2019/12/17 16:23:55 UTC
[camel-kafka-connector] branch rearrange-date-time created (now
f04f2f8)
This is an automated email from the ASF dual-hosted git repository.
oalsafi pushed a change to branch rearrange-date-time
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
at f04f2f8 Add checkstyle profile and rename sub modules in poms
This branch includes the following new commits:
new f04f2f8 Add checkstyle profile and rename sub modules in poms
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[camel-kafka-connector] 01/01: Add checkstyle profile and rename
sub modules in poms
Posted by oa...@apache.org.
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 <om...@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);
- }
+ }
}
}