|
31 | 31 | import org.apache.flink.table.api.config.ExecutionConfigOptions;
|
32 | 32 |
|
33 | 33 | import org.apache.kafka.clients.producer.ProducerConfig;
|
34 |
| -import org.junit.Before; |
35 |
| -import org.junit.Test; |
| 34 | +import org.junit.jupiter.api.BeforeEach; |
| 35 | +import org.junit.jupiter.api.Test; |
36 | 36 |
|
37 | 37 | import java.time.Duration;
|
38 | 38 | import java.time.ZoneId;
|
|
44 | 44 | import static org.apache.flink.streaming.connectors.kafka.table.KafkaTableTestUtils.waitingExpectedResults;
|
45 | 45 |
|
46 | 46 | /** IT cases for Kafka with changelog format for Table API & SQL. */
|
47 |
| -public class KafkaChangelogTableITCase extends KafkaTableTestBase { |
| 47 | +class KafkaChangelogTableITCase extends KafkaTableTestBase { |
48 | 48 |
|
49 |
| - @Before |
50 |
| - public void before() { |
| 49 | + @BeforeEach |
| 50 | + void before() { |
51 | 51 | // we have to use single parallelism,
|
52 | 52 | // because we will count the messages in sink to terminate the job
|
53 | 53 | env.setParallelism(1);
|
54 | 54 | }
|
55 | 55 |
|
56 | 56 | @Test
|
57 |
| - public void testKafkaDebeziumChangelogSource() throws Exception { |
| 57 | + void testKafkaDebeziumChangelogSource() throws Exception { |
58 | 58 | final String topic = "changelog_topic";
|
59 | 59 | createTestTopic(topic, 1, 1);
|
60 | 60 |
|
@@ -180,7 +180,7 @@ public void testKafkaDebeziumChangelogSource() throws Exception {
|
180 | 180 | }
|
181 | 181 |
|
182 | 182 | @Test
|
183 |
| - public void testKafkaCanalChangelogSource() throws Exception { |
| 183 | + void testKafkaCanalChangelogSource() throws Exception { |
184 | 184 | final String topic = "changelog_canal";
|
185 | 185 | createTestTopic(topic, 1, 1);
|
186 | 186 |
|
@@ -320,7 +320,7 @@ public void testKafkaCanalChangelogSource() throws Exception {
|
320 | 320 | }
|
321 | 321 |
|
322 | 322 | @Test
|
323 |
| - public void testKafkaMaxwellChangelogSource() throws Exception { |
| 323 | + void testKafkaMaxwellChangelogSource() throws Exception { |
324 | 324 | final String topic = "changelog_maxwell";
|
325 | 325 | createTestTopic(topic, 1, 1);
|
326 | 326 |
|
|
0 commit comments