Minor fix in test.

codefeedr · Apr 1, 2019 · ee1c5e3 · ee1c5e3
1 parent 1186bbc
commit ee1c5e3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/codefeedr-core/src/test/scala/org/codefeedr/buffer/KafkaBufferTest.scala b/codefeedr-core/src/test/scala/org/codefeedr/buffer/KafkaBufferTest.scala
@@ -170,7 +170,7 @@ class KafkaBufferTest
     correctProperties.put("enable.auto.commit", "true")
     correctProperties.put("group.id", "test")
     correctProperties.put("some.other.property", "some-value")
-    correctDefaultProperties.put("compression.type", "none")
+    correctProperties.put("compression.type", "none")
     assert(kafkaBuffer2.getKafkaProperties == correctProperties)
 
   }