Skip to content

Commit 462be6d

Browse files
authored
KAFKA-12196: Migrate connect:api module to JUnit 5 (apache#9909)
Reviewers: Chia-Ping Tsai <[email protected]>, Ismael Juma <[email protected]>
1 parent 962b69b commit 462be6d

23 files changed

+154
-208
lines changed

build.gradle

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -242,7 +242,7 @@ subprojects {
242242
}
243243

244244
// Remove the relevant project name once it's converted to JUnit 5
245-
def shouldUseJUnit5 = !(["api", "connect", "core", "generator", "runtime", "examples",
245+
def shouldUseJUnit5 = !(["connect", "core", "generator", "runtime", "examples",
246246
"streams-scala", "streams"].contains(it.project.name) || it.project.name.startsWith("upgrade-system-tests-"))
247247

248248
def testLoggingEvents = ["passed", "skipped", "failed"]
@@ -1850,9 +1850,7 @@ project(':connect:api') {
18501850
compile libs.slf4jApi
18511851
compile libs.jaxrsApi
18521852

1853-
testCompile libs.junitJupiterApi
1854-
testCompile libs.junitVintageEngine
1855-
1853+
testCompile libs.junitJupiter
18561854
testRuntime libs.slf4jlog4j
18571855
testCompile project(':clients').sourceSets.test.output
18581856
}

connect/api/src/test/java/org/apache/kafka/connect/connector/ConnectorReconfigurationTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,14 +19,14 @@
1919
import org.apache.kafka.common.config.ConfigDef;
2020
import org.apache.kafka.connect.errors.ConnectException;
2121

22-
import org.junit.Test;
22+
import org.junit.jupiter.api.Test;
2323

2424
import java.util.Collections;
2525
import java.util.List;
2626
import java.util.Map;
2727

28-
import static org.junit.Assert.assertEquals;
29-
import static org.junit.Assert.assertThrows;
28+
import static org.junit.jupiter.api.Assertions.assertEquals;
29+
import static org.junit.jupiter.api.Assertions.assertThrows;
3030

3131
public class ConnectorReconfigurationTest {
3232

connect/api/src/test/java/org/apache/kafka/connect/connector/ConnectorTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,16 +21,16 @@
2121
import java.util.List;
2222
import java.util.Map;
2323

24-
import org.junit.Before;
25-
import org.junit.Test;
24+
import org.junit.jupiter.api.BeforeEach;
25+
import org.junit.jupiter.api.Test;
2626

2727
public abstract class ConnectorTest {
2828

2929
protected ConnectorContext context;
3030
protected Connector connector;
3131
protected AssertableConnector assertableConnector;
3232

33-
@Before
33+
@BeforeEach
3434
public void beforeEach() {
3535
connector = createConnector();
3636
context = createContext();

connect/api/src/test/java/org/apache/kafka/connect/data/ConnectSchemaTest.java

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
package org.apache.kafka.connect.data;
1818

1919
import org.apache.kafka.connect.errors.DataException;
20-
import org.junit.Test;
20+
import org.junit.jupiter.api.Test;
2121

2222
import java.math.BigDecimal;
2323
import java.math.BigInteger;
@@ -28,10 +28,10 @@
2828
import java.util.HashMap;
2929
import java.util.Map;
3030

31-
import static org.junit.Assert.assertEquals;
32-
import static org.junit.Assert.assertNotEquals;
33-
import static org.junit.Assert.assertNull;
34-
import static org.junit.Assert.assertThrows;
31+
import static org.junit.jupiter.api.Assertions.assertEquals;
32+
import static org.junit.jupiter.api.Assertions.assertNotEquals;
33+
import static org.junit.jupiter.api.Assertions.assertNull;
34+
import static org.junit.jupiter.api.Assertions.assertThrows;
3535

3636
public class ConnectSchemaTest {
3737
private static final Schema MAP_INT_STRING_SCHEMA = SchemaBuilder.map(Schema.INT32_SCHEMA, Schema.STRING_SCHEMA).build();
@@ -69,8 +69,7 @@ public void testFieldsOnStructSchema() {
6969

7070
@Test
7171
public void testFieldsOnlyValidForStructs() {
72-
assertThrows(DataException.class,
73-
() -> Schema.INT8_SCHEMA.fields());
72+
assertThrows(DataException.class, Schema.INT8_SCHEMA::fields);
7473
}
7574

7675
@Test

connect/api/src/test/java/org/apache/kafka/connect/data/DateTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,14 @@
1717
package org.apache.kafka.connect.data;
1818

1919
import org.apache.kafka.connect.errors.DataException;
20-
import org.junit.Test;
20+
import org.junit.jupiter.api.Test;
2121

2222
import java.util.Calendar;
2323
import java.util.GregorianCalendar;
2424
import java.util.TimeZone;
2525

26-
import static org.junit.Assert.assertEquals;
27-
import static org.junit.Assert.assertThrows;
26+
import static org.junit.jupiter.api.Assertions.assertEquals;
27+
import static org.junit.jupiter.api.Assertions.assertThrows;
2828

2929
public class DateTest {
3030
private static final GregorianCalendar EPOCH;

connect/api/src/test/java/org/apache/kafka/connect/data/DecimalTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,14 +16,14 @@
1616
*/
1717
package org.apache.kafka.connect.data;
1818

19-
import org.junit.Test;
19+
import org.junit.jupiter.api.Test;
2020

2121
import java.math.BigDecimal;
2222
import java.math.BigInteger;
2323
import java.util.Collections;
2424

25-
import static org.junit.Assert.assertArrayEquals;
26-
import static org.junit.Assert.assertEquals;
25+
import static org.junit.jupiter.api.Assertions.assertArrayEquals;
26+
import static org.junit.jupiter.api.Assertions.assertEquals;
2727

2828
public class DecimalTest {
2929
private static final int TEST_SCALE = 2;

connect/api/src/test/java/org/apache/kafka/connect/data/FieldTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,10 +16,10 @@
1616
*/
1717
package org.apache.kafka.connect.data;
1818

19-
import org.junit.Test;
19+
import org.junit.jupiter.api.Test;
2020

21-
import static org.junit.Assert.assertEquals;
22-
import static org.junit.Assert.assertNotEquals;
21+
import static org.junit.jupiter.api.Assertions.assertEquals;
22+
import static org.junit.jupiter.api.Assertions.assertNotEquals;
2323

2424
public class FieldTest {
2525

connect/api/src/test/java/org/apache/kafka/connect/data/SchemaBuilderTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
package org.apache.kafka.connect.data;
1818

1919
import org.apache.kafka.connect.errors.SchemaBuilderException;
20-
import org.junit.Test;
20+
import org.junit.jupiter.api.Test;
2121

2222
import java.nio.ByteBuffer;
2323
import java.util.Arrays;
@@ -26,9 +26,9 @@
2626
import java.util.List;
2727
import java.util.Map;
2828

29-
import static org.junit.Assert.assertEquals;
30-
import static org.junit.Assert.assertNull;
31-
import static org.junit.Assert.assertThrows;
29+
import static org.junit.jupiter.api.Assertions.assertEquals;
30+
import static org.junit.jupiter.api.Assertions.assertNull;
31+
import static org.junit.jupiter.api.Assertions.assertThrows;
3232

3333
public class SchemaBuilderTest {
3434
private static final String NAME = "name";

0 commit comments

Comments
 (0)