[ 
https://issues.apache.org/jira/browse/KAFKA-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933233#comment-17933233
 ] 

PoAn Yang commented on KAFKA-18938:
-----------------------------------

[~rameshkanna], could you try latest 3.9 branch?

1. Modify following fields in `config/kraft/controller.properties`.
{noformat}
node.id=2
listeners=CONTROLLER://:9094
advertised.listeners=CONTROLLER://localhost:9094
{noformat}
2. Format first node with `config/kraft/server.properties` and start it.
{noformat}
> ./bin/kafka-storage.sh format -t "zuV6tFqAQhSGfFe97O-9cw" --config 
> ./config/kraft/server.properties --standalone

Formatting dynamic metadata voter directory /tmp/kraft-combined-logs with 
metadata.version 3.9-IV0.

> ./bin/kafka-server-start.sh ./config/kraft/server.properties
{noformat}
3. Format second node with `config/kraft/controller.properties` and start it.
{noformat}
> ./bin/kafka-storage.sh format -t "zuV6tFqAQhSGfFe97O-9cw" --config 
> ./config/kraft/controller.properties --no-initial-controllers

Formatting metadata directory /tmp/kraft-controller-logs with metadata.version 
3.9-IV0.

> ./bin/kafka-server-start.sh ./config/kraft/controller.properties
{noformat}
4. Describe cluster status. There is one voter and one observer.
{noformat}
> ./bin/kafka-metadata-quorum.sh --bootstrap-controller localhost:9093 describe 
> --status

ClusterId:              zuV6tFqAQhSGfFe97O-9cw
LeaderId:               1
LeaderEpoch:            1
HighWatermark:          959
MaxFollowerLag:         0
MaxFollowerLagTimeMs:   0
CurrentVoters:          [{"id": 1, "directoryId": "eDoUCgrMQ8CdTH4UUBkBOw", 
"endpoints": ["CONTROLLER://localhost:9093"]}]
CurrentObservers:       [{"id": 2, "directoryId": "93g3C9kCS3qDz75w8NH8UQ"}]
{noformat}
5. Add second node as controller.
{noformat}
> ./bin/kafka-metadata-quorum.sh --bootstrap-controller localhost:9093 
> --command-config ./config/kraft/controller.properties add-controller

Added controller 2 with directory id 93g3C9kCS3qDz75w8NH8UQ and endpoints: 
CONTROLLER://localhost:9094
{noformat}
6. Describe cluster status again and there are two voters.
{noformat}
> ./bin/kafka-metadata-quorum.sh --bootstrap-controller localhost:9093 describe 
> --status

ClusterId:              zuV6tFqAQhSGfFe97O-9cw
LeaderId:               1
LeaderEpoch:            1
HighWatermark:          1093
MaxFollowerLag:         0
MaxFollowerLagTimeMs:   0
CurrentVoters:          [{"id": 1, "directoryId": "eDoUCgrMQ8CdTH4UUBkBOw", 
"endpoints": ["CONTROLLER://localhost:9093"]}, {"id": 2, "directoryId": 
"93g3C9kCS3qDz75w8NH8UQ", "endpoints": ["CONTROLLER://localhost:9094"]}]
CurrentObservers:       []
{noformat}

> Kraft version and metadata version wrongly showing
> --------------------------------------------------
>
>                 Key: KAFKA-18938
>                 URL: https://issues.apache.org/jira/browse/KAFKA-18938
>             Project: Kafka
>          Issue Type: Bug
>          Components: controller, kraft
>    Affects Versions: 3.9.0
>            Reporter: Rameshkanna N
>            Priority: Major
>
> I am using Kafka {*}3.9.0{*}. When starting a {*}KRaft controller{*}, it 
> shows {*}metadata version 3.0-IV1{*}, but when formatting storage, it shows 
> {*}version 3.9-IV0{*}. When I try to confirm the version using:
> {{sh kafka-features.sh --bootstrap-controller localhost:9091 describe}}
> it shows {*}finalized KRaft version 0{*}.
> Can anyone help me resolve this issue?
> Logs:
> sh kafka-features.sh --bootstrap-controller localhost:9091 describe
> Feature: kraft.version    SupportedMinVersion: 0    SupportedMaxVersion: 1    
> FinalizedVersionLevel: 0    Epoch: 6
> Feature: metadata.version    SupportedMinVersion: 3.0-IV1    
> SupportedMaxVersion: 3.9-IV0  
>  FinalizedVersionLevel: 3.9-IV0    Epoch: 6
> Server.log:
> [2025-03-06 13:40:40,569] INFO [ControllerServer id=102] Waiting for all of 
> the SocketServer Acceptors to be started (kafka.server.ControllerServer)
> [2025-03-06 13:40:40,569] INFO [ControllerServer id=102] Finished waiting for 
> all of the SocketServer Acceptors to be started 
> (kafka.server.ControllerServer)
> [2025-03-06 13:40:40,569] INFO [ControllerRegistrationManager id=102 
> incarnation=h-3EozNTQZGbhcsV_119Fg] initialized channel manager. 
> (kafka.server.ControllerRegistrationManager)
> [2025-03-06 13:40:40,569] INFO [ControllerRegistrationManager id=102 
> incarnation=h-3EozNTQZGbhcsV_119Fg] maybeSendControllerRegistration: cannot 
> register yet because the metadata.version is still 3.0-IV1, which does not 
> support KIP-919 controller registration.



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

Reply via email to