[camel] branch master updated: Camel-Kafka: Fixed tests

[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.git


The following commit(s) were added to refs/heads/master by this push:
     new e0bb890  Camel-Kafka: Fixed tests
e0bb890 is described below

commit e0bb89025133c8442bb61fb81622d237ed16e675
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Dec 1 14:25:35 2020 +0100

    Camel-Kafka: Fixed tests
---
 .../org/apache/camel/component/kafka/KafkaComponentTest.java | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
index 6af3393..9be5b3b 100644
--- 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
+++ 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
@@ -79,20 +79,20 @@ public class KafkaComponentTest extends CamelTestSupport {
         assertEquals("broker1:12345,broker2:12566", 
endpoint.getConfiguration().getBrokers());
         assertEquals("mytopic", endpoint.getConfiguration().getTopic());
         assertEquals("com.class.Party", 
endpoint.getConfiguration().getPartitioner());
-        assertEquals("123", 
endpoint.getConfiguration().getAdditionalProperties().get("extra.1"));
-        assertEquals("test", 
endpoint.getConfiguration().getAdditionalProperties().get("extra.2"));
+        assertEquals(789, 
endpoint.getConfiguration().getAdditionalProperties().get("extra.1"));
+        assertEquals(null, 
endpoint.getConfiguration().getAdditionalProperties().get("extra.2"));
         assertEquals("test.extra.3", 
endpoint.getConfiguration().getAdditionalProperties().get("extra.3"));
 
         // test properties on producer keys
         final Properties producerProperties = 
endpoint.getConfiguration().createProducerProperties();
-        assertEquals("123", producerProperties.getProperty("extra.1"));
-        assertEquals("test", producerProperties.getProperty("extra.2"));
+        assertEquals("789", producerProperties.getProperty("extra.1"));
+        assertEquals(null, producerProperties.getProperty("extra.2"));
         assertEquals("test.extra.3", 
producerProperties.getProperty("extra.3"));
 
         // test properties on consumer keys
         final Properties consumerProperties = 
endpoint.getConfiguration().createConsumerProperties();
-        assertEquals("123", consumerProperties.getProperty("extra.1"));
-        assertEquals("test", consumerProperties.getProperty("extra.2"));
+        assertEquals("789", consumerProperties.getProperty("extra.1"));
+        assertEquals(null, consumerProperties.getProperty("extra.2"));
         assertEquals("test.extra.3", 
producerProperties.getProperty("extra.3"));
     }