2017-12-28 29 views
0

우리 애플리케이션은 다양한 유형의 큐를 사용합니다. 대기열을 사용하는 응용 프로그램을 시작하기 전에는 필요한 대기열에 샘플 메시지를 쓰고 대기열이 올바르게 설정되어 있는지 확인하기 위해 해당 대기열을 읽는 (즉, 삭제하는) 자동화 된 사전 점검이 있습니다.카프카 토픽이 올바르게 설정되었는지 테스트하기

이제는 카프카도 사용합니다. 그러나 카프카에서는 주제를 "오염시키는"일종의 실제 응용 프로그램을 시작하기 전에 메시지를 삭제할 수 없으므로 주제로 메시지를 작성하고 읽음으로써 사전 점검을 수행 할 수 없습니다. 카프카에서 자동화 된 다른 방법, API 또는 명령 줄 스크립트가 있습니까? 자바 또는 쉘 스크립트에서 선호됩니다.

카프카 버전 0.11.x

답변

2

kafka-topics --describe --topic YOUR_TOPIC --zookeeper YOUR_ZK은 충분해야한다. 동기화되어있는 활성 복제본이있는 출력이 있으면 잘 수행해야합니다. 다른 도구는 kafkacat이며, 기본 제공 도구가 필요한 도구를 제공하지 않는 경우 (즉, ZooKeeper에 액세스 할 수 없거나 액세스하지 않으려는 경우)입니다.