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 인스턴스의 explainCluster() 메서드를 사용하여 Kafka 클러스터의 버전 정보를 쿼리합니다. 마지막으로 Kafka 클러스터의 버전 정보를 인쇄합니다.

Notes

• Kafka 버전 쿼리 명령은 Kafka 클러스터의 버전 정보만 쿼리할 수 있습니다. 단일 Kafka 노드의 버전 정보를 쿼리할 수 없습니다.
• Kafka 버전 쿼리 명령은 Kafka 클러스터의 현재 버전 정보만 쿼리할 수 있습니다. Kafka 클러스터의 기록 버전 정보를 쿼리할 수 없습니다.
• Kafka 버전 쿼리 명령은 읽기 전용 명령입니다. Kafka 클러스터에는 아무런 영향을 미치지 않습니다.

위 내용은 Kafka 버전 쿼리 명령: 관련 정보를 빠르게 가져옵니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!