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() {