File tree 12 files changed +32
-33
lines changed
main/java/org/springframework/kafka/test
test/java/org/springframework/kafka/test
12 files changed +32
-33
lines changed Original file line number Diff line number Diff line change 38
38
import java .util .function .Function ;
39
39
import java .util .stream .Collectors ;
40
40
41
+ import kafka .server .KafkaConfig ;
42
+ import kafka .testkit .KafkaClusterTestKit ;
43
+ import kafka .testkit .TestKitNodes ;
41
44
import org .apache .commons .logging .LogFactory ;
42
45
import org .apache .kafka .clients .CommonClientConfigs ;
43
46
import org .apache .kafka .clients .admin .AdminClient ;
54
57
import org .springframework .core .log .LogAccessor ;
55
58
import org .springframework .util .Assert ;
56
59
57
- import kafka .server .KafkaConfig ;
58
- import kafka .testkit .KafkaClusterTestKit ;
59
- import kafka .testkit .TestKitNodes ;
60
-
61
60
/**
62
61
* An embedded Kafka Broker(s) using KRaft.
63
62
* This class is intended to be used in the unit tests.
Original file line number Diff line number Diff line change 16
16
17
17
package org .springframework .kafka .test ;
18
18
19
- import static org .assertj .core .api .Assertions .assertThat ;
20
-
21
19
import org .junit .jupiter .api .Test ;
22
20
23
21
import org .springframework .util .StringUtils ;
24
22
23
+ import static org .assertj .core .api .Assertions .assertThat ;
24
+
25
25
/**
26
26
* @author Gary Russell
27
27
* @since 3.1
Original file line number Diff line number Diff line change 16
16
17
17
package org .springframework .kafka .test ;
18
18
19
- import static org .assertj .core .api .Assertions .assertThat ;
20
-
21
19
import org .junit .jupiter .api .Test ;
22
20
21
+ import static org .assertj .core .api .Assertions .assertThat ;
22
+
23
23
/**
24
24
* @author Gary Russell
25
25
* @since 2.3
Original file line number Diff line number Diff line change 16
16
17
17
package org .springframework .kafka .test .assertj ;
18
18
19
+ import org .apache .kafka .clients .consumer .ConsumerRecord ;
20
+ import org .junit .jupiter .api .Test ;
21
+
19
22
import static org .assertj .core .api .Assertions .allOf ;
20
23
import static org .assertj .core .api .Assertions .assertThat ;
21
24
import static org .springframework .kafka .test .assertj .KafkaConditions .keyValue ;
22
25
import static org .springframework .kafka .test .assertj .KafkaConditions .partition ;
23
26
24
- import org .apache .kafka .clients .consumer .ConsumerRecord ;
25
- import org .junit .jupiter .api .Test ;
26
-
27
27
/**
28
28
* @author Gary Russell
29
29
* @since 2.2.12
Original file line number Diff line number Diff line change 16
16
17
17
package org .springframework .kafka .test .condition ;
18
18
19
- import static org .assertj .core .api .Assertions .assertThat ;
20
-
21
19
import org .junit .jupiter .api .Test ;
22
20
23
21
import org .springframework .kafka .test .EmbeddedKafkaBroker ;
24
22
import org .springframework .kafka .test .EmbeddedKafkaZKBroker ;
25
23
import org .springframework .kafka .test .context .EmbeddedKafka ;
26
24
import org .springframework .kafka .test .utils .KafkaTestUtils ;
27
25
26
+ import static org .assertj .core .api .Assertions .assertThat ;
27
+
28
28
/**
29
29
* @author Gary Russell
30
30
* @author Michał Padula
Original file line number Diff line number Diff line change 16
16
17
17
package org .springframework .kafka .test .condition ;
18
18
19
- import static org .assertj .core .api .Assertions .assertThat ;
20
-
21
19
import java .util .List ;
22
20
import java .util .concurrent .atomic .AtomicInteger ;
23
21
31
29
import org .springframework .test .annotation .DirtiesContext ;
32
30
import org .springframework .test .context .junit .jupiter .SpringJUnitConfig ;
33
31
32
+ import static org .assertj .core .api .Assertions .assertThat ;
33
+
34
34
/**
35
35
* @author Lee Jaeheon
36
36
* @author Soby Chacko
Original file line number Diff line number Diff line change 16
16
17
17
package org .springframework .kafka .test .condition ;
18
18
19
- import static org .assertj .core .api .Assertions .assertThat ;
20
-
21
19
import org .junit .jupiter .api .Test ;
22
20
23
21
import org .springframework .beans .factory .annotation .Autowired ;
27
25
import org .springframework .test .annotation .DirtiesContext ;
28
26
import org .springframework .test .context .junit .jupiter .SpringJUnitConfig ;
29
27
28
+ import static org .assertj .core .api .Assertions .assertThat ;
29
+
30
30
/**
31
31
* @author Gary Russell
32
32
* @since 2.7.2
Original file line number Diff line number Diff line change 16
16
17
17
package org .springframework .kafka .test .context ;
18
18
19
- import static org .assertj .core .api .Assertions .assertThat ;
20
-
21
19
import org .junit .jupiter .api .BeforeEach ;
22
20
import org .junit .jupiter .api .Test ;
23
21
27
25
import org .springframework .kafka .test .EmbeddedKafkaBroker ;
28
26
import org .springframework .kafka .test .utils .KafkaTestUtils ;
29
27
28
+ import static org .assertj .core .api .Assertions .assertThat ;
29
+
30
30
/**
31
31
* @author Oleg Artyomov
32
32
* @author Sergio Lourenco
Original file line number Diff line number Diff line change 16
16
17
17
package org .springframework .kafka .test .hamcrest ;
18
18
19
- import static org .assertj .core .api .Assertions .assertThatExceptionOfType ;
20
- import static org .hamcrest .MatcherAssert .assertThat ;
21
- import static org .springframework .kafka .test .hamcrest .KafkaMatchers .hasKey ;
22
- import static org .springframework .kafka .test .hamcrest .KafkaMatchers .hasPartition ;
23
- import static org .springframework .kafka .test .hamcrest .KafkaMatchers .hasTimestamp ;
24
- import static org .springframework .kafka .test .hamcrest .KafkaMatchers .hasValue ;
25
-
26
19
import java .util .Optional ;
27
20
28
21
import org .apache .kafka .clients .consumer .ConsumerRecord ;
29
22
import org .apache .kafka .common .header .internals .RecordHeaders ;
30
23
import org .apache .kafka .common .record .TimestampType ;
31
24
import org .junit .jupiter .api .Test ;
32
25
26
+ import static org .assertj .core .api .Assertions .assertThatExceptionOfType ;
27
+ import static org .hamcrest .MatcherAssert .assertThat ;
28
+ import static org .springframework .kafka .test .hamcrest .KafkaMatchers .hasKey ;
29
+ import static org .springframework .kafka .test .hamcrest .KafkaMatchers .hasPartition ;
30
+ import static org .springframework .kafka .test .hamcrest .KafkaMatchers .hasTimestamp ;
31
+ import static org .springframework .kafka .test .hamcrest .KafkaMatchers .hasValue ;
32
+
33
33
/**
34
34
* @author Biju Kunjummen
35
35
*
Original file line number Diff line number Diff line change 16
16
17
17
package org .springframework .kafka .test .junit ;
18
18
19
- import static org .assertj .core .api .Assertions .assertThat ;
20
-
21
19
import java .io .BufferedOutputStream ;
22
20
import java .io .File ;
23
21
import java .io .FileOutputStream ;
49
47
50
48
import org .springframework .util .DefaultPropertiesPersister ;
51
49
50
+ import static org .assertj .core .api .Assertions .assertThat ;
51
+
52
52
/**
53
53
* @author Artem Bilan
54
54
*
Original file line number Diff line number Diff line change 16
16
17
17
package org .springframework .kafka .test .rule ;
18
18
19
- import static org .assertj .core .api .Assertions .assertThat ;
20
-
21
19
import java .io .IOException ;
22
20
import java .net .ServerSocket ;
23
21
import java .util .Map ;
39
37
import org .springframework .test .annotation .DirtiesContext ;
40
38
import org .springframework .test .context .junit .jupiter .SpringJUnitConfig ;
41
39
40
+ import static org .assertj .core .api .Assertions .assertThat ;
41
+
42
42
/**
43
43
* @author Gary Russell
44
44
* @author Kamill Sokol
Original file line number Diff line number Diff line change 16
16
17
17
package org .springframework .kafka .test .utils ;
18
18
19
- import static org .assertj .core .api .Assertions .assertThat ;
20
- import static org .assertj .core .api .Assertions .assertThatExceptionOfType ;
21
-
22
19
import java .time .Duration ;
23
20
import java .util .List ;
24
21
import java .util .Map ;
38
35
import org .springframework .kafka .test .EmbeddedKafkaBroker ;
39
36
import org .springframework .kafka .test .context .EmbeddedKafka ;
40
37
38
+ import static org .assertj .core .api .Assertions .assertThat ;
39
+ import static org .assertj .core .api .Assertions .assertThatExceptionOfType ;
40
+
41
41
/**
42
42
* @author Gary Russell
43
43
* @author Artem Bilan
You can’t perform that action at this time.
0 commit comments