From 2bb2b5ebe721d7b95423753626941e8496f11248 Mon Sep 17 00:00:00 2001 From: Arkadiy Date: Fri, 28 Aug 2020 13:40:12 +0300 Subject: [PATCH] Use consumer properties for SimpleConsumerConfig --- .../main/java/io/confluent/kafkarest/SimpleConsumerFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka-rest/src/main/java/io/confluent/kafkarest/SimpleConsumerFactory.java b/kafka-rest/src/main/java/io/confluent/kafkarest/SimpleConsumerFactory.java index f3d21a8b94..55451ab3a0 100644 --- a/kafka-rest/src/main/java/io/confluent/kafkarest/SimpleConsumerFactory.java +++ b/kafka-rest/src/main/java/io/confluent/kafkarest/SimpleConsumerFactory.java @@ -35,7 +35,7 @@ public SimpleConsumerFactory(final KafkaRestConfig config) { this.config = config; clientIdCounter = new AtomicInteger(0); - simpleConsumerConfig = new SimpleConsumerConfig(config.getOriginalProperties()); + simpleConsumerConfig = new SimpleConsumerConfig(config.getConsumerProperties()); } public SimpleConsumerConfig getSimpleConsumerConfig() {