Mac용 Apache Kafka 클라이언트

브로커 하나의 호스트·포트를 입력하면 나머지 클러스터를 찾습니다. Additional Bootstrap Servers는 첫 브로커가 응답하지 않을 때 시도할 목록입니다. 연결 하나는 클러스터 하나로 Database 필드는 없고 사이드바에 토픽이 바로 표시됩니다.

Security Protocol은 PLAINTEXT, SSL, SASL_PLAINTEXT 또는 SASL_SSL이며 SASL Mechanism은 PLAIN, SCRAM-SHA-256 또는 SCRAM-SHA-512입니다. PLAIN은 Confluent Cloud, SCRAM은 Amazon MSK·자체 호스팅 브로커에 맞습니다. SSL·SASL_SSL에서 SSL 모드를 선택하지 않으면 인증서 체인·호스트 이름을 검사합니다. 사설 CA는 CA Certificate에 넣고 클라이언트 인증서·키는 상호 TLS를 추가합니다.

SSH 터널에서는 부트스트랩 브로커에만 연결해 그 브로커가 리더인 파티션만 읽습니다. Import from URL…는 kafka:// URL을 받지만 macOS는 링크로 열지 않습니다.

토픽을 열면 최근 메시지를 최신이 마지막인 순서로 표시하며 파티션, 오프셋, 타임스탬프, 키, 값, 헤더와 크기가 나옵니다. 읽기 편하도록 다른 파티션 메시지를 시간순으로 섞지만 메시지 식별자는 파티션·오프셋입니다. UTF-8이 아닌 키·값은 십육진수로 표시하고 tombstone은 빈 메시지와 구별합니다.

KafkaQL은 정렬·필터 대신 시작 위치를 씁니다. CONSUME "orders" FROM NEWEST, FROM OLDEST, FROM OFFSET 또는 ISO 8601 시간의 FROM TIME이며 일부 파티션만 지정할 수도 있습니다. SHOW TOPICS, SHOW BROKERS, SHOW GROUPS, SHOW CLUSTER, DESCRIBE TOPIC으로 나머지 클러스터 정보를 봅니다.

DESCRIBE GROUP은 파티션별 커밋 오프셋, 끝 오프셋과 차이를 보여 주는 지연 보고입니다. 그룹이 커밋한 적 없는 파티션은 0부터 계산하지 않고 지연 없음으로 표시합니다. 브로커에 접근 못하면 SHOW GROUPS는 목록이 잘렸다고 표시합니다.

PRODUCE INTO는 선택 키·헤더·파티션으로 메시지를 씁니다. 키가 있고 파티션이 없으면 Kafka 자체 프로듀서와 같은 위치로 보냅니다. gzip, snappy, lz4, zstd 배치는 읽으며 압축을 풀고 별도 설정은 없습니다.

Kafka에는 업데이트, 메시지별 삭제나 서버 측 정렬이 없어 셀 편집·행 삭제·열 정렬을 할 수 없고 해당 컨트롤이 흐리게 표시됩니다. 각 페이지는 이전 끝에서 이어져 쓰기 중인 토픽에서도 메시지를 반복하거나 건너뛰지 않습니다.

사이드바나 DROP TOPIC으로 토픽 삭제가 유일한 파괴적 작업입니다. 클러스터가 나중에 로그를 제거해 잠시 목록에 남을 수 있습니다. Kafka는 보존 정책이나 파티션별 오프셋으로 레코드를 제거하며 둘 다 토픽을 비우지 않아 Truncate는 없습니다.

가져오기는 없으며 PRODUCE INTO로 토픽에 메시지를 넣습니다. 쿼리가 읽은 메시지를 CSV, JSON 또는 XLSX로 내보냅니다.

iPhone과 iPad 앱에는 Apache Kafka 드라이버가 없습니다. Mac에서 동기화한 Apache Kafka 연결은 목록에 표시되지만 열리지 않습니다.