File tree Expand file tree Collapse file tree 2 files changed +6
-2
lines changed
src/test/java/com/mongodb/kafka/connect/source Expand file tree Collapse file tree 2 files changed +6
-2
lines changed Original file line number Diff line number Diff line change 76
76
77
77
import org .apache .kafka .common .config .ConfigException ;
78
78
import org .junit .jupiter .api .DisplayName ;
79
+ import org .junit .jupiter .api .Nested ;
79
80
import org .junit .jupiter .api .Test ;
80
81
81
82
import org .bson .BsonTimestamp ;
@@ -546,7 +547,8 @@ void testHeartbeatTopicName() {
546
547
.getString (HEARTBEAT_TOPIC_NAME_CONFIG )));
547
548
}
548
549
549
- static final class StartupModeTest {
550
+ @ Nested
551
+ final class StartupModeTest {
550
552
@ Test
551
553
void startupMode () {
552
554
assertAll (
Original file line number Diff line number Diff line change 31
31
import org .apache .kafka .connect .storage .OffsetStorageReader ;
32
32
import org .junit .jupiter .api .AfterEach ;
33
33
import org .junit .jupiter .api .BeforeEach ;
34
+ import org .junit .jupiter .api .Nested ;
34
35
import org .junit .jupiter .api .Test ;
35
36
import org .mockito .ArgumentCaptor ;
36
37
45
46
import com .mongodb .kafka .connect .source .statistics .JmxStatisticsManager ;
46
47
47
48
final class StartedMongoSourceTaskTest {
48
- static final class ChangeStreamIterableOptionsTest {
49
+ @ Nested
50
+ final class ChangeStreamIterableOptionsTest {
49
51
private final Map <String , String > properties = new HashMap <>();
50
52
private StartedMongoSourceTask task ;
51
53
You can’t perform that action at this time.
0 commit comments