You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/24 22:47:00 UTC
[jira] [Updated] (KAFKA-16192) Introduce usage of flexible records to coordinators

     [ https://issues.apache.org/jira/browse/KAFKA-16192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Justine Olshan updated KAFKA-16192:
-----------------------------------
    Description: 
[KIP-915|https://cwiki.apache.org/confluence/display/KAFKA/KIP-915%3A+Txn+and+Group+Coordinator+Downgrade+Foundation] introduced flexible versions to the records used for the group and transaction coordinators.
However, the KIP did not update the record version used.

For [KIP-890|https://cwiki.apache.org/confluence/display/KAFKA/KIP-890%3A+Transactions+Server-Side+Defense] we intend to use flexible fields in the transaction state records. This requires a safe way to upgrade from non-flexible version records to flexible version records.

This change is implemented via MV.

  was:
[KIP-915| https://cwiki.apache.org/confluence/display/KAFKA/KIP-915%3A+Txn+and+Group+Coordinator+Downgrade+Foundation] introduced flexible versions to the records used for the group and transaction coordinators.
However, the KIP did not update the record version used.

For [KIP-890|https://cwiki.apache.org/confluence/display/KAFKA/KIP-890%3A+Transactions+Server-Side+Defense] we intend to use flexible fields in the transaction state records. This requires a safe way to upgrade from non-flexible version records to flexible version records.

Typically this is done as a message format bump. There may be an option to make this change using MV since if the readers of the records are internal and not external consumers.


> Introduce usage of flexible records to coordinators
> ---------------------------------------------------
>
>                 Key: KAFKA-16192
>                 URL: https://issues.apache.org/jira/browse/KAFKA-16192
>             Project: Kafka
>          Issue Type: Task
>            Reporter: Justine Olshan
>            Assignee: Justine Olshan
>            Priority: Major
>
> [KIP-915|https://cwiki.apache.org/confluence/display/KAFKA/KIP-915%3A+Txn+and+Group+Coordinator+Downgrade+Foundation] introduced flexible versions to the records used for the group and transaction coordinators.
> However, the KIP did not update the record version used.
> For [KIP-890|https://cwiki.apache.org/confluence/display/KAFKA/KIP-890%3A+Transactions+Server-Side+Defense] we intend to use flexible fields in the transaction state records. This requires a safe way to upgrade from non-flexible version records to flexible version records.
> This change is implemented via MV.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)