Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-192: KafkaEmbedded Lifecycle Methods to Public

Browse Source 
Resolves https://github.com/spring-projects/spring-kafka/issues/192
This commit is contained in:
Gary Russell
2016-10-12 15:55:25 -04:00
committed by Artem Bilan
parent 076a352104
commit a148e4af31
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-kafka-test/src/main/java/org/springframework/kafka/test/rule/KafkaEmbedded.java
View File

@@ -129,7 +129,7 @@ public class KafkaEmbedded extends ExternalResource implements KafkaRule {
}
@Override
protected void before() throws Exception { //NOSONAR
public void before() throws Exception { //NOSONAR
startZookeeper();
int zkConnectionTimeout = 6000;
int zkSessionTimeout = 6000;
@@ -163,7 +163,7 @@ public class KafkaEmbedded extends ExternalResource implements KafkaRule {
}
@Override
protected void after() {
public void after() {
System.getProperties().remove(SPRING_EMBEDDED_KAFKA_BROKERS);
for (KafkaServer kafkaServer : this.kafkaServers) {
try {