Skip to content

Commit

Permalink
Add specific kafka broker configuration support
Browse files Browse the repository at this point in the history
  • Loading branch information
hamzei committed Feb 19, 2019
1 parent 449d4a6 commit cb8c2e7
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 8 deletions.
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@

<groupId>ir.sahab</groupId>
<artifactId>kafka-rule</artifactId>
<version>1.2</version>
<version>1.3</version>

<repositories>
<repository>
Expand Down
7 changes: 0 additions & 7 deletions src/test/java/ir/sahab/kafkarule/KafkaRuleTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -31,13 +31,6 @@ public class KafkaRuleTest {
@ClassRule
public static KafkaRule kafkaRuleWithSelfManagedZk = new KafkaRule();

private static Properties properties = new Properties();
static {
properties.setProperty("a","b");
}
@ClassRule
public static KafkaRule kafkaRuleWithSpecificProperties = new KafkaRule(properties);

@BeforeClass
public static void before() {
kafkaRuleWithSelfManagedZk.createTopic(TOPIC_NAME, 1);
Expand Down

0 comments on commit cb8c2e7

Please sign in to comment.