Repository: camel
Updated Branches:
  refs/heads/master 680ee9e0c -> 82bd0baab


CAMEL-9957 Fixed the casting error in KafkaProducerTest


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/82bd0baa
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/82bd0baa
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/82bd0baa

Branch: refs/heads/master
Commit: 82bd0baab2dcc4659c68919117b24dd9a8e17ebf
Parents: 680ee9e
Author: Willem Jiang <willem.ji...@gmail.com>
Authored: Thu May 12 09:13:21 2016 +0800
Committer: Willem Jiang <willem.ji...@gmail.com>
Committed: Thu May 12 09:14:23 2016 +0800

----------------------------------------------------------------------
 .../java/org/apache/camel/component/kafka/KafkaProducerTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/82bd0baa/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
----------------------------------------------------------------------
diff --git 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
index 7c52629..68798f3 100644
--- 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
+++ 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
@@ -57,7 +57,7 @@ public class KafkaProducerTest {
         Future future = Mockito.mock(Future.class);
         Mockito.when(future.get()).thenReturn(rm);
         org.apache.kafka.clients.producer.KafkaProducer kp = 
Mockito.mock(org.apache.kafka.clients.producer.KafkaProducer.class);
-        Mockito.when(kp.send(Mockito.any())).thenReturn(future);
+        
Mockito.when(kp.send(Mockito.any(ProducerRecord.class))).thenReturn(future);
 
         producer.setKafkaProducer(kp);
     }

Reply via email to