[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787499#comment-17787499 ]
Phuc Hong Tran commented on KAFKA-15341: ---------------------------------------- [~showuon] [~satish.duggana] I’m trying to add remote storage enable status as a new field to BrokerRegistrationRequestData, however there is this “_version” variable (I assumed it is api version or the data version) that is used when read or write the registration data to from or to a byte array. Since I’m adding a new field, I assume that I need to increase the version number, do you guys know how that _version number is determined? Thanks > Enabling TS for a topic during rolling restart causes problems > -------------------------------------------------------------- > > Key: KAFKA-15341 > URL: https://issues.apache.org/jira/browse/KAFKA-15341 > Project: Kafka > Issue Type: Bug > Reporter: Divij Vaidya > Assignee: Phuc Hong Tran > Priority: Major > Labels: KIP-405 > Fix For: 3.7.0 > > > When we are in a rolling restart to enable TS at system level, some brokers > have TS enabled on them and some don't. We send an alter config call to > enable TS for a topic, it hits a broker which has TS enabled, this broker > forwards it to the controller and controller will send the config update to > all brokers. When another broker which doesn't have TS enabled (because it > hasn't undergone the restart yet) gets this config change, it "should" fail > to apply it. But failing now is too late since alterConfig has already > succeeded since controller->broker config propagation is done async. > With this JIRA, we want to have controller check if TS is enabled on all > brokers before applying alter config to turn on TS for a topic. > Context: https://github.com/apache/kafka/pull/14176#discussion_r1291265129 -- This message was sent by Atlassian Jira (v8.20.10#820010)