You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/07/01 21:30:05 UTC

[PR] KAFKA-20760: Fix for Position integration test and persiting Position object [kafka]

bbejeck opened a new pull request, #22727:
URL: https://github.com/apache/kafka/pull/22727

   Two defects surfaced when parameterizing the PositionRestartIntegrationTest for transactional state stores
    
     1. ClassCastException on IQv2 RangeQuery/TimestampedRangeQuery
   
     An IQv2 `RangeQuery` or `TimestampedRangeQuery` against a transactional
     store threw:
   
         java.lang.ClassCastException: class StagedMergeIterator cannot be cast
         to class RocksDbIterator
             at KeyValueToTimestampedKeyValueByteStoreAdapter.query(...)
   
     `KeyValueToTimestampedKeyValueByteStoreAdapter.query` cast the range
     result to `RocksDbIterator`; a transactional store returns a StagedMergeIterator
   
    
   
   2. Committed Position not restored after restart
   
     After a clean close and reopen, a position-bound IQv2 query against a
     transactional store timed out with `NOT_UP_TO_BOUND` because the persisted
     Position came back empty/stale:
   
         current position Position{position={}} is not yet up to the bound ...
   
     The committed Position was staged into the transaction buffer's write
     batch by the `writePosition()` checkpoint callback but never flushed, and
     the batch is discarded on close.
   


-- 
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: jira-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] KAFKA-20760: Fix for PositionRestartIntegrationTest and persisting Position object [kafka]

Posted by "bbejeck (via GitHub)" <gi...@apache.org>.
bbejeck closed pull request #22727: KAFKA-20760: Fix for PositionRestartIntegrationTest and persisting Position object
URL: https://github.com/apache/kafka/pull/22727


-- 
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: jira-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org