[
https://issues.apache.org/jira/browse/KAFKA-14993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14993:
------------------------------
Description:
RSM should throw a ResourceNotFoundException if it does not have
TransactionIndex. Currently, it expects an empty InputStream and creates an
unnecessary file in the cache. This can be avoided by catching
ResourceNotFoundException and not creating an instance. There are minor
cleanups needed in RemoteIndexCache and other TransactionIndex usages.
Also, update the LocalTieredStorage, see
[this|https://github.com/apache/kafka/pull/13837#discussion_r1258917584]
comment.
Note, please remember to update the javadoc in RSM after the fix. See:
https://github.com/apache/kafka/pull/14352
was:
RSM should throw a ResourceNotFoundException if it does not have
TransactionIndex. Currently, it expects an empty InputStream and creates an
unnecessary file in the cache. This can be avoided by catching
ResourceNotFoundException and not creating an instance. There are minor
cleanups needed in RemoteIndexCache and other TransactionIndex usages.
Also, update the LocalTieredStorage, see
[this|https://github.com/apache/kafka/pull/13837#discussion_r1258917584]
comment.
> Improve TransactionIndex instance handling while copying to and fetching from
> RSM.
> ----------------------------------------------------------------------------------
>
> Key: KAFKA-14993
> URL: https://issues.apache.org/jira/browse/KAFKA-14993
> Project: Kafka
> Issue Type: Improvement
> Components: core
> Reporter: Satish Duggana
> Assignee: Kamal Chandraprakash
> Priority: Major
> Labels: tiered-storage
> Fix For: 3.7.0
>
>
> RSM should throw a ResourceNotFoundException if it does not have
> TransactionIndex. Currently, it expects an empty InputStream and creates an
> unnecessary file in the cache. This can be avoided by catching
> ResourceNotFoundException and not creating an instance. There are minor
> cleanups needed in RemoteIndexCache and other TransactionIndex usages.
> Also, update the LocalTieredStorage, see
> [this|https://github.com/apache/kafka/pull/13837#discussion_r1258917584]
> comment.
> Note, please remember to update the javadoc in RSM after the fix. See:
> https://github.com/apache/kafka/pull/14352
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
