kafkacat

kcat(이전의 kafkacat)은 Apache Kafka® 배포를 테스트 및 디버그하는 데 사용할 수 있는 명령줄 유틸리티입니다.

kcat을 사용하여 Kafka topic에 대해 produce, consume 및 list 할 수 있습니다. "netcat for Kafka"로 설명되는 이 도구는 Kafka에서 데이터를 검사하고 생성하기 위한 도구입니다.

 

kafkacat 설치

 sudo apt install kafkacat

 

Consumer Mode

Consumer 모드에서 kcat은 주제 및 파티션에서 메시지를 읽고 출력합니다.

Kafka 브로커( -b)와 topic( -t)를 지정해야 합니다. 

kcat에 브로커( -b) 및 topic( -t)에 대한 내용을 볼 수 있습니다.

 kafkacat -b localhost:9092 -t mysql_users
% Auto-selecting Consumer mode (use -P or -C to override)
{"uid":1,"name":"Cliff","locale":"en_US","address_city":"St Louis","elite":"P"}
{"uid":2,"name":"Nick","locale":"en_US","address_city":"Palo Alto","elite":"G"}
[...]

 

 

Producer Mode

In producer mode, kcat reads messages from standard input (stdin). You must specify a Kafka broker (-b) and topic (-t). You can optionally specify a delimiter (-D). The default delimiter is newline.

You can easily send data to a topic using kcat. Run it with the -P command and enter the data you want, and then press Ctrl-D to finish:

Producer 모드에서 kcat은 표준 입력(stdin)에서 메시지를 읽습니다. Kafka 브로커( -b)와 주제( -t)를 지정해야 합니다.

kcat을 사용하여 주제에 데이터를 보낼 수 있습니다. -P 명령 으로 실행하고원하는 데이터를 입력한 다음 Ctrl-D 를 눌러 완료합니다.

kafkacat -b localhost:9092 -t new_topic -P

test

 

 

Metadata Listing Mode

메타데이터 목록 모드( -L)에서 kcat은 Kafka 클러스터와 주제, 파티션, 복제본 및 동기화 복제본(ISR)의 현재 상태를 표시합니다.

kafkacat -b localhost:9092 -L

 

JSON( -J) 옵션을 추가하여 출력을 JSON으로 내보냅니다.

kafkacat -b mybroker -L -J

 

kcat example code

kcat의 Hello World 예제는 kcat: Apache Kafka®  예제를 참조하세요. 모든 예에는 온프레미스 또는 Confluent Cloud에서 실행되는 모든 Kafka 클러스터에 연결할 수 있는 생산자 및 소비자가 포함됩니다.