Kafka版本查詢指令：快速取得相關信息

Kafka版本查詢指令

Kafka版本查詢指令用於查詢Kafka叢集的版本資訊。此指令的語法如下：

kafka-topics --version

此指令的輸出範例如下：

kafka-topics --version
kafka-topics version 2.7.0

此輸出範例顯示Kafka叢集的版本為2.7.0。

具體程式碼範例

以下是使用Kafka版本查詢指令的具體程式碼範例：

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();
    }
}

該程式碼範例首先建立了一個AdminClient實例。然後，它使用AdminClient實例的describeCluster()方法查詢Kafka叢集的版本資訊。最後，它列印Kafka叢集的版本資訊。

注意事項

• Kafka版本查詢指令只能查詢Kafka叢集的版本資訊。它不能查詢單一Kafka節點的版本資訊。
• Kafka版本查詢指令只能查詢Kafka叢集的目前版本資訊。它不能查詢Kafka叢集的歷史版本資訊。
• Kafka版本查詢指令是一個唯讀指令。它不會對Kafka叢集造成任何影響。

以上是Kafka版本查詢指令：快速取得相關信息的詳細內容。更多資訊請關注PHP中文網其他相關文章！