Add specific kafka broker configuration support

sahabpardaz · Feb 19, 2019 · d9c5419 · d9c5419
1 parent 449d4a6
commit d9c5419
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/test/java/ir/sahab/kafkarule/KafkaRuleTest.java b/src/test/java/ir/sahab/kafkarule/KafkaRuleTest.java
@@ -33,7 +33,7 @@ public class KafkaRuleTest {
 
     private static Properties properties = new Properties();
     static {
-        properties.setProperty("a","b");
+        properties.setProperty("message.max.bytes","5000000");
     }
     @ClassRule
     public static KafkaRule kafkaRuleWithSpecificProperties = new KafkaRule(properties);