(flink-connector-kafka) branch main updated: [hotfix] update reader idleness test output (#281)

[bli]

This is an automated email from the ASF dual-hosted git repository.

bowenli86 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git


The following commit(s) were added to refs/heads/main by this push:
     new 6a109ae4 [hotfix] update reader idleness test output (#281)
6a109ae4 is described below

commit 6a109ae49c061b5e07935d0b8551c3914ea4fa8e
Author: bowenli86 <bowenl...@gmail.com>
AuthorDate: Fri Jun 26 10:46:57 2026 -0700

    [hotfix] update reader idleness test output (#281)
---
 .../kafka/dynamic/source/reader/DynamicKafkaSourceReaderTest.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReaderTest.java
 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReaderTest.java
index fea90b72..c7a4ec2a 100644
--- 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReaderTest.java
+++ 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReaderTest.java
@@ -342,7 +342,7 @@ public class DynamicKafkaSourceReaderTest extends 
SourceReaderTestBase<DynamicKa
     void testNotifyNoMoreSplits() throws Exception {
         TestingReaderContext context = new TestingReaderContext();
         try (DynamicKafkaSourceReader<Integer> reader = 
createReaderWithoutStart(context)) {
-            TestingReaderOutput<Integer> readerOutput = new 
TestingReaderOutput<>();
+            TrackingReaderOutput<Integer> readerOutput = new 
TrackingReaderOutput<>();
             reader.start();
 
             // Splits assigned