THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
=== 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 } |
...