From a148e4af31162e5cfd1d9b170118d4a29b0b671e Mon Sep 17 00:00:00 2001
From: Gary Russell <grussell@pivotal.io>
Date: Wed, 12 Oct 2016 15:55:25 -0400
Subject: [PATCH] GH-192: KafkaEmbedded Lifecycle Methods to Public

Resolves https://github.com/spring-projects/spring-kafka/issues/192
---
 .../org/springframework/kafka/test/rule/KafkaEmbedded.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/spring-kafka-test/src/main/java/org/springframework/kafka/test/rule/KafkaEmbedded.java b/spring-kafka-test/src/main/java/org/springframework/kafka/test/rule/KafkaEmbedded.java
index d3765bff..d74e3465 100644
--- a/spring-kafka-test/src/main/java/org/springframework/kafka/test/rule/KafkaEmbedded.java
+++ b/spring-kafka-test/src/main/java/org/springframework/kafka/test/rule/KafkaEmbedded.java
@@ -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 {