[camel-kafka-connector] branch master updated: Cleaning up

[acosentino]

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 <anco...@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());
         } 
     }