Page History

=== DESCRIBE FEATURES ===

# DescribeGet cluster-wide finalized features, and features supported cluster-wideby a specific broker.
#  - Use `--bootstrap-server` Optionally,to provide a broker host:port to which thequeries `ApiVersions` query should be issued.
#  - Optionally, If this is not provided, a random broker in the cluster will be picked to serve this request.provide `--controller` flag directing the tool to issue the query to the
#  - Optionally, provide --controller flag(while directingdiscovering the toolcontroller to issuevia the query only to the controllerbootstrap server).
#    This can be useful for debugging purposes.
$> kafka-features.sh describe [--bootstrap-server kafka-broker0.prn1:9071] [--controller]

{
	"status": "OK",
	"supported_features": {
		"group_coordinator": {
            "minVersion": 1,
            "maxVersion": 2
        },
        "transaction_coordinator": {
        	"minVersion": 0,
        	"maxVersion": 5
        },
        "consumer_offsets_topic_schema": { 
            "minVersion": 3,
        	"maxVersion": 7
        }
	},
	"finalized_features": {
        "group_coordinator": {
            "version": 1
        },
        "transaction_coordinator": {
        	"version": 4
        },
        "consumer_offsets_topic_schema": { 
            "version": 7
        }
   },
   "host": "kafka-broker0.prn1",
   "port": 9071
}

=== ADD_OR_UPDATE FEATURES ===

# UpdateAdd or update a list of cluster-wide finalized features.
#  - Provide the type of update, ex: Use `--bootstrap-server` to provide a broker host:port to which MetadataRequest query should be issued.
#    The MetadataResponse will be used to discover the Controller, to which the actual ADD_OR_UPDATE, DELETE request is issued.
#  - Use `--features` Provideto provide a comma-separated list of features and their new finalized versions to updateADD_OR_UPDATE.

$> kafka-features.sh update --updatebootstrap-type ADD_OR_UPDATEserver kafka-broker0.prn1:9071 --features group_coordinator:2,transaction_coordinator:5

Please confirm before finalizing the upgrade of the following features:
1. group_coordinator from v1 (existing) to v2 (new)
2. transaction_coordinator from v4 (existing) to v5 (new)

[Y/n]? Y

{
	"status": "OK",
	"supported_features": {
		"group_coordinator": {
            "minVersion": 1,
            "maxVersion": 2
        },
        "transaction_coordinator": {
        	"minVersion": 0,
        	"maxVersion": 5
        },
        "consumer_offsets_topic_schema": { 
            "minVersion": 3,
        	"maxVersion": 7
        }
	},
	"finalized_features": {
        "group_coordinator": {
            "version": 2
        },
        "transaction_coordinator": {
        	"version": 5
        },
        "consumer_offsets_topic_schema": { 
            "version": 7
        }
   },
   "host": "kafka-broker0.prn1",
   "port": 9071
}

=== DELETE FEATURES ===

# Delete a list of cluster-wide finalized features.
#  - Use `- Provide-bootstrap-server` to provide a broker host:port to which MetadataRequest query should be issued.
#    The MetadataResponse will be used to discover the Controller, to which the typeactual ofdelete update,request ex:is DELETEissued.
#  - Provide Use `--features` to provide a comma-separated list of features to be deleted.

$> kafka-features.sh updatedelete --updatebootstrap-type DELETEserver kafka-broker0.prn1:9071 --features group_coordinator,transaction_coordinator

Please confirm deletion of the following features:
1. group_coordinator
2. transaction_coordinator

[Y/n] Y

{
	"status": "OK",
	"supported_features": {
		"group_coordinator": {
            "minVersion": 1,
            "maxVersion": 2
        },
        "transaction_coordinator": {
        	"minVersion": 0,
        	"maxVersion": 5
        },
        "consumer_offsets_topic_schema": { 
            "minVersion": 3,
        	"maxVersion": 7
        }
	},
	"finalized_features": {
        "consumer_offsets_topic_schema": { 
            "version": 7
        }
   },
   "host": "kafka-broker0.prn1",
   "port": 9071
}