[camel-kafka-connector] branch master updated: Fix Kafka instance type should read from the property not from the system env

[ac...@apache.org]

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 bee619a  Fix Kafka instance type should read from the property not from the system env
     new 2464b1a  Merge pull request #42 from orpiske/use-property-not-env
bee619a is described below

commit bee619a1acc1f126325e39a3347a197617c7a75b
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Wed Dec 11 17:59:50 2019 +0100

    Fix Kafka instance type should read from the property not from the system env
---
 .../apache/camel/kafkaconnector/services/kafka/KafkaServiceFactory.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/src/test/java/org/apache/camel/kafkaconnector/services/kafka/KafkaServiceFactory.java b/tests/src/test/java/org/apache/camel/kafkaconnector/services/kafka/KafkaServiceFactory.java
index b276912..f3ab9a7 100644
--- a/tests/src/test/java/org/apache/camel/kafkaconnector/services/kafka/KafkaServiceFactory.java
+++ b/tests/src/test/java/org/apache/camel/kafkaconnector/services/kafka/KafkaServiceFactory.java
@@ -27,7 +27,7 @@ public final class KafkaServiceFactory {
     }
 
     public static KafkaService createService() {
-        String kafkaRemote = System.getenv("kafka.instance.type");
+        String kafkaRemote = System.getProperty("kafka.instance.type");
         if (kafkaRemote == null || kafkaRemote.equals("local-kafka-container")) {
             return new ContainerLocalKafkaService();
         }