diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java index 83d181ed1..9a9cdd85b 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderJaasInitTests.java @@ -24,6 +24,7 @@ import org.apache.kafka.common.security.JaasUtils; import org.apache.kafka.streams.kstream.KStream; import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.springframework.boot.WebApplicationType; @@ -57,6 +58,12 @@ public class KafkaStreamsBinderJaasInitTests { } } + @BeforeEach + public void before() { + System.clearProperty(JaasUtils.JAVA_LOGIN_CONFIG_PARAM); + javax.security.auth.login.Configuration.setConfiguration(null); + } + @Test void testKafkaStreamsBinderJaasInitialization() { ConfigurableApplicationContext applicationContext = new SpringApplicationBuilder(