분산 이벤트 스트리밍 플랫폼 → 메시지 브로커 참조
기본 개념
설치
Mac (Homebrew)
brew install kafka
brew services start kafkaSASL 컨슈머 설정
SASL_PLAINTEXT: username/password 기반 인증 방식
/usr/local/etc/kafka/consumer.properties (brew 설치 기준):
group.id=ted-consumer-group
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
username="ted" \
password="hwang";컨슈밍 시작:
/usr/local/bin/kafka-console-consumer \
--bootstrap-server kafka.ted-site.me:9092 \
--consumer.config /usr/local/etc/kafka/consumer.properties \
--topic TEST_TOPIC \
--from-beginningDocker Compose 구성
# docker-compose.yaml 예시 (Kafka + Zookeeper)
version: '3'
services:
zookeeper:
image: confluentinc/cp-zookeeper:latest
environment:
ZOOKEEPER_CLIENT_PORT: 2181
kafka:
image: confluentinc/cp-kafka:latest
depends_on:
- zookeeper
ports:
- "9092:9092"
environment:
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092관련 노트
- kafkactl - Kafka CLI 관리 도구
- 메시지 브로커 - 메시지 브로커 개요 및 비교
- Docker - Docker Compose 기반 Kafka 구성
- 분산 환경과 서비스 - 분산 시스템 아키텍처