Kafka version query command
The Kafka version query command is used to query the version information of the Kafka cluster. The syntax of this command is as follows:
kafka-topics --version
The output example of this command is as follows:
kafka-topics --version kafka-topics version 2.7.0
This output example indicates that the version of the Kafka cluster is 2.7.0.
Specific code example
The following is a specific code example using the Kafka version query command:
import org.apache.kafka.clients.admin.AdminClient; import org.apache.kafka.clients.admin.KafkaAdminClient; public class KafkaVersionQuery { public static void main(String[] args) { // Create an AdminClient instance AdminClient adminClient = KafkaAdminClient.create(KafkaProperties.get()); // Query the Kafka cluster version String version = adminClient.describeCluster().version().toString(); // Print the Kafka cluster version System.out.println("Kafka cluster version: " + version); // Close the AdminClient instance adminClient.close(); } }
This code example first creates an AdminClient instance . It then queries the version information of the Kafka cluster using the describeCluster() method of the AdminClient instance. Finally, it prints the version information of the Kafka cluster.
Note
The above is the detailed content of Kafka version query command: quickly obtain relevant information. For more information, please follow other related articles on the PHP Chinese website!