You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2019/12/17 06:57:58 UTC
[camel-kafka-connector] branch master updated: Cleaning up
This is an automated email from the ASF dual-hosted git repository.
acosentino 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 dd90fad Cleaning up
dd90fad is described below
commit dd90fad515a84dc7f4c8290abc28ed6929d6e847
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Dec 17 07:38:50 2019 +0100
Cleaning up
---
.../java/org/apache/camel/kafkaconnector/CamelSinkTask.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
index 8e180d5..26dba4a 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
@@ -78,7 +78,7 @@ public class CamelSinkTask extends SinkTask {
Exchange exchange = new DefaultExchange(producer.getCamelContext());
for (SinkRecord record : sinkRecords) {
headers.put(KAFKA_RECORD_KEY_HEADER, record.key());
- for (Iterator iterator = record.headers().iterator(); iterator.hasNext();) {
+ for (Iterator<Header> iterator = record.headers().iterator(); iterator.hasNext();) {
Header header = (Header)iterator.next();
if (header.key().startsWith(HEADER_CAMEL_PREFIX)) {
addHeader(headers, header);
@@ -126,9 +126,9 @@ public class CamelSinkTask extends SinkTask {
} else if (schema.type().getName().equalsIgnoreCase(Schema.INT8_SCHEMA.type().getName())) {
map.put(singleHeader.key(), (byte)singleHeader.value());
} else if (schema.type().getName().equalsIgnoreCase(SchemaBuilder.map(Schema.STRING_SCHEMA, Schema.STRING_SCHEMA).type().getName())) {
- map.put(singleHeader.key(), (Map)singleHeader.value());
+ map.put(singleHeader.key(), (Map<?, ?>)singleHeader.value());
} else if (schema.type().getName().equalsIgnoreCase(SchemaBuilder.array(Schema.STRING_SCHEMA).type().getName())) {
- map.put(singleHeader.key(), (List)singleHeader.value());
+ map.put(singleHeader.key(), (List<?>)singleHeader.value());
}
}
@@ -153,9 +153,9 @@ public class CamelSinkTask extends SinkTask {
} else if (schema.type().getName().equalsIgnoreCase(Schema.INT8_SCHEMA.type().getName())) {
exchange.getProperties().put(singleHeader.key(), (byte)singleHeader.value());
} else if (schema.type().getName().equalsIgnoreCase(SchemaBuilder.map(Schema.STRING_SCHEMA, Schema.STRING_SCHEMA).type().getName())) {
- exchange.getProperties().put(singleHeader.key(), (Map)singleHeader.value());
+ exchange.getProperties().put(singleHeader.key(), (Map<?, ?>)singleHeader.value());
} else if (schema.type().getName().equalsIgnoreCase(SchemaBuilder.array(Schema.STRING_SCHEMA).type().getName())) {
- exchange.getProperties().put(singleHeader.key(), (List)singleHeader.value());
+ exchange.getProperties().put(singleHeader.key(), (List<?>)singleHeader.value());
}
}