[camel] 03/03: CAMEL-16138: Allow KafkaClientFactory to be used without explicit broker URLs

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit c71771cfb06d74b7c326c84532fbe9990d9cf637
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue Feb 9 07:50:27 2021 +0100

    CAMEL-16138: Allow KafkaClientFactory to be used without explicit broker URLs
---
 .../test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java
index e0a397d..eff7f14 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java
@@ -38,7 +38,7 @@ public class KafkaConsumerTest {
         when(endpoint.getConfiguration()).thenReturn(configuration);
         when(endpoint.getConfiguration().getGroupId()).thenReturn("groupOne");
         when(component.getKafkaClientFactory()).thenReturn(clientFactory);
-        when(clientFactory.getBrokers(any())).thenReturn(null);
+        when(clientFactory.getBrokers(any())).thenThrow(new IllegalArgumentException());
         assertThrows(IllegalArgumentException.class,
                 () -> new KafkaConsumer(endpoint, processor).getProps());
     }