This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
commit 485ef9e0c1cbddc3b8d1bf9e81ffa4757b1c86d3 Author: Sergey Nuyanzin <snuyan...@gmail.com> AuthorDate: Mon Aug 1 10:23:00 2022 +0200 [FLINK-28768][tests][testinfrastructure] Update junit to 5.9.1 --- .../java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java b/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java index e350846..726ecee 100644 --- a/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java +++ b/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java @@ -70,7 +70,7 @@ import static org.assertj.core.api.Assertions.assertThat; /** smoke test for the kafka connectors. */ @ExtendWith({TestLoggerExtension.class}) @Testcontainers -public class SmokeKafkaITCase { +class SmokeKafkaITCase { private static final Logger LOG = LoggerFactory.getLogger(SmokeKafkaITCase.class); private static final String INTER_CONTAINER_KAFKA_ALIAS = "kafka"; @@ -107,7 +107,7 @@ public class SmokeKafkaITCase { } @BeforeAll - private static void setUp() { + static void setUp() { final Map<String, Object> adminProperties = new HashMap<>(); adminProperties.put( CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, @@ -122,7 +122,7 @@ public class SmokeKafkaITCase { } @AfterAll - private static void teardown() { + static void teardown() { admin.close(); producer.close(); }