Zongwen Li created FLINK-25510:
----------------------------------
Summary: Add test cases for KafkaPartitionSplitReader
Key: FLINK-25510
URL: https://issues.apache.org/jira/browse/FLINK-25510
Project: Flink
Issue Type: Improvement
Components: Connectors / Kafka
Affects Versions: 1.14.2
Reporter: Zongwen Li
I see that KafkaPartitionSplitReaderTest is missing the test case when
startingOffset is COMMITTED_OFFSET.
Can you assign a ticket to me?
--
This message was sent by Atlassian Jira
(v8.20.1#820001)