Apache Kafka

트리에서 마우스 오른쪽 버튼 클릭 ▸ 추가 ▸ Kafka 요청.

공통 설정

필드	역할
URL	쉼표로 구분한 브로커 목록: hote1:9092,hote2:9092 — 문자열 전체가 분할되기 전에 Handlebars로 해석됩니다
클라이언트 ID	브로커에 알리는 clientId
토픽	모드와 무관하게 사용되는 토픽
모드	produce, consume 또는 browse

인증

필드	값
SASL 메커니즘	none, plain, scram-sha-256, scram-sha-512
SASL 사용자 / SASL 비밀번호	비밀번호에는 비밀 값 유형의 값을 지정할 수 있습니다
TLS	독립적으로 켤 수 있습니다 — SASL 없이 TLS만 쓰는 브로커는 none 메커니즘으로 동작합니다

produce 모드

키, 값, 레코드 헤더, 그리고 선택적으로 파티션을 지정합니다. 파티션을 명시하지 않으면 클라이언트 라이브러리의 기본 파티셔너가 적용됩니다. 응답으로는 기록된 레코드의 메타데이터, 즉 토픽과 파티션, 오프셋이 돌아옵니다.

consume 모드

필드	역할
그룹	컨슈머의 groupId
시작 오프셋	earliest, latest 또는 specific
특정 오프셋	문자열 — Kafka의 오프셋은 64 비트 정수입니다
파티션	클라이언트 측 필터입니다. 파티션 할당 자체는 그룹이 담당합니다

browse 모드

컨슈머 그룹 없이 파티션을 살펴봅니다. Restorm은 정해진 개수의 메시지를 꺼낸 뒤 연결을 끊습니다. 이 모드에서는 파티션이 필수입니다.

그룹을 만들거나 오프셋을 옮기지 않고 토픽에 무엇이 들어 있는지 보고 싶을 때 알맞은 도구입니다.

시나리오에서

• Kafka produce — 단발 액션이며 레코드의 메타데이터를 반환합니다.
• Kafka consume — 컨슈머 그룹을 통해 구독하고 메시지마다 이벤트를 내보냅니다.
• Kafka 연결 닫기 — 소비를 중단합니다.

연결과 스트리밍을 참고하십시오.

코드 스니펫

다섯 가지 대상이 있습니다. JavaScript(kafkajs, 생성과 소비)와 kcat(생성, 소비, 그룹 없는 조회)입니다.