From 203a82e046bea79dd9dc206ac4c8ab5b48400e47 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Mon, 10 Jul 2023 15:17:35 -0400 Subject: [PATCH] Kafka Streams binder security test changes - Invalidate security configuration in Kafka Streams binder security related tests. See the previous commit for more details. --- .../streams/bootstrap/KafkaStreamsBinderJaasInitTests.java | 7 +++++++ 1 file changed, 7 insertions(+) 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(