mumrah commented on PR #17397: URL: https://github.com/apache/kafka/pull/17397#issuecomment-2444352725
Verified that things look good on trunk. When comparing the two test catalogs generated before and after [this commit](https://github.com/apache/kafka/commit/4817eb9227bc54225f9d24dcdc496f545538a67e#diff-d2d5426c1d8b525415735ad409e82d4ff34ea3712a8217e4a99b421e470d4c19R1284), we see: ``` diff --git a/streams/tests.yaml b/streams/tests.yaml index 3f2250a..ded0055 100644 --- a/streams/tests.yaml +++ b/streams/tests.yaml @@ -2440,6 +2440,7 @@ org.apache.kafka.streams.processor.internals.PartitionGroupTest: - shouldThrowIllegalStateExceptionUponAddRecordsIfPartitionUnknown - shouldThrowIllegalStateExceptionUponGetHeadRecordOffsetIfPartitionUnknown - shouldThrowIllegalStateExceptionUponGetPartitionTimestampIfPartitionUnknown +- shouldThrowIllegalStateExceptionUponHeadRecordLeaderEpochIfPartitionUnknown - shouldThrowIllegalStateExceptionUponNumBufferedIfPartitionUnknown - shouldThrowIllegalStateExceptionUponSetPartitionTimestampIfPartitionUnknown - shouldUpdateLags @@ -2905,7 +2906,7 @@ org.apache.kafka.streams.processor.internals.StreamTaskTest: - shouldClearCommitStatusesInCloseDirty - shouldClearTaskTimeout - shouldCloseStateManagerEvenDuringFailureOnUncleanTaskClose -- shouldCommitConsumerPositionIfRecordQueueIsEmpty +- shouldCommitFetchedNextOffsetIfRecordQueueIsEmpty - shouldCommitNextOffsetAndProcessorMetadataFromQueueIfAvailable - shouldCommitOldProcessorMetadataWhenNotDirty - shouldFailOnCommitIfTaskIsClosed ``` which matches the changes in that commit -- 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]
