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:44:56 UTC
[camel-kafka-connector] branch master updated: Clean up
This is an automated email from the ASF dual-hosted git repository.
oalsafi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/master by this push:
new e989f4b Clean up
e989f4b is described below
commit e989f4b7d8fa93b466e3e00852451dda5931488b
Author: Omar Al-Safi <om...@gmail.com>
AuthorDate: Tue Dec 17 17:44:46 2019 +0100
Clean up
---
.../org/apache/camel/kafkaconnector/CamelSourceTask.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 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..65af7c6 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
@@ -91,8 +91,8 @@ public class CamelSourceTask extends SourceTask {
@Override
public synchronized List<SourceRecord> poll() {
- Long startPollEpochMilli = Instant.now().toEpochMilli();
- Long collectedRecords = 0L;
+ long startPollEpochMilli = Instant.now().toEpochMilli();
+ long collectedRecords = 0L;
List<SourceRecord> records = new ArrayList<>();
@@ -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);
- }
+ }
}
}