[
https://issues.apache.org/jira/browse/KAFKA-10401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marek updated KAFKA-10401:
--------------------------
Description:
While reading group metadata information from ByteBuffer GroupMetadataManager
reads current_state_timestamp only for group schema version 2. For all other
versions this value is set to "None".
Piece of code responsible for the bug:
[https://github.com/apache/kafka/blob/2.6.0/core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala#L1412]
Restarting kafka forces GroupMetadataManager manager to reload group metadata
from file basically causing
[KIP-211|[https://cwiki.apache.org/confluence/display/KAFKA/KIP-211%3A+Revise+Expiration+Semantics+of+Consumer+Group+Offsets]]
to be only applicable for schema version 2.
was:
While reading group metadata information from ByteBuffer GroupMetadataManager
reads current_state_timestamp only for group schema version 2. For all other
versions this value is set to "None".
Piece of code responsible for the bug:
[https://github.com/apache/kafka/blob/2.6.0/core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala#L1412]
Restarting kafka forces GroupMetadataManager manager to reload group metadata
from file basically causing
[KIP-211|[https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals?src=breadcrumbs-parent]]
to be only applicable for schema version 2.
> GroupMetadataManager ignores current_state_timestamp field for
> GROUP_METADATA_VALUE_SCHEMA_V3
> ---------------------------------------------------------------------------------------------
>
> Key: KAFKA-10401
> URL: https://issues.apache.org/jira/browse/KAFKA-10401
> Project: Kafka
> Issue Type: Bug
> Components: offset manager
> Affects Versions: 2.1.1, 2.2.2, 2.4.1, 2.6.0, 2.5.1
> Reporter: Marek
> Priority: Major
>
> While reading group metadata information from ByteBuffer GroupMetadataManager
> reads current_state_timestamp only for group schema version 2. For all other
> versions this value is set to "None".
> Piece of code responsible for the bug:
> [https://github.com/apache/kafka/blob/2.6.0/core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala#L1412]
> Restarting kafka forces GroupMetadataManager manager to reload group metadata
> from file basically causing
> [KIP-211|[https://cwiki.apache.org/confluence/display/KAFKA/KIP-211%3A+Revise+Expiration+Semantics+of+Consumer+Group+Offsets]]
> to be only applicable for schema version 2.
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
