From d9c5419cdc330da5eecd15f585f29bde9cedbe79 Mon Sep 17 00:00:00 2001 From: hamzei Date: Tue, 19 Feb 2019 12:38:33 +0330 Subject: [PATCH] Add specific kafka broker configuration support --- src/test/java/ir/sahab/kafkarule/KafkaRuleTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/test/java/ir/sahab/kafkarule/KafkaRuleTest.java b/src/test/java/ir/sahab/kafkarule/KafkaRuleTest.java index 2ce429e..263bb0b 100644 --- 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);