xiaochen-zhou commented on code in PR #9598:
URL: https://github.com/apache/seatunnel/pull/9598#discussion_r2250046659
##########
seatunnel-connectors-v2/connector-kafka/src/test/java/org/apache/kafka/clients/admin/KafkaSourceSplitEnumeratorTest.java:
##########
@@ -145,12 +166,50 @@ void addplits() throws ExecutionException,
InterruptedException {
new HashMap<TopicPartition, KafkaSourceSplit>();
Map<TopicPartition, KafkaSourceSplit> pendingSplit = new HashMap<>();
List<KafkaSourceSplit> splits =
- Collections.singletonList(new KafkaSourceSplit(null,
partition));
+ Arrays.asList(
+ new KafkaSourceSplit(null, partition0),
+ new KafkaSourceSplit(null, partition2));
+
KafkaSourceSplitEnumerator enumerator =
new KafkaSourceSplitEnumerator(adminClient, pendingSplit,
assignedSplit, false);
enumerator.fetchPendingPartitionSplit();
Assertions.assertEquals(pendingSplit.size(), splits.size());
- Assertions.assertNotNull(pendingSplit.get(partition));
- Assertions.assertTrue(pendingSplit.get(partition).getEndOffset() == 0);
+ Assertions.assertNotNull(pendingSplit.get(partition0));
+ Assertions.assertTrue(pendingSplit.get(partition0).getEndOffset() ==
0);
+ }
+
+ @Test
+ void testIgnoreNoLeaderPartition() throws ExecutionException,
InterruptedException {
Review Comment:
> The test case need check for `After the partitions are restored, the
dynamic partition discovery mechanism will automatically detect and include
these restored partitions, making them available for use.`
Done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
