Kafka 설치

카프카 설치

http://kafka.apache.org/

주키퍼 실행

bin/zookeeper-server-start.sh config/zookeeper.properties

Properties 변경

server.properties에서 Listner 설정을 추가해 줘야 한다.

listeners=PLAINTEXT://127.0.0.1:9092

kafka 실행

bin/kafka-server-start.sh config/server.properties

Topic 생성

bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

Producer

bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

Consumer

bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

Kafka Producer

Kafka Producer 는 데이터를 Kafka 로 보내는 역할을 한다.

  • Topic 에 해당하는 메시지를 생성 후 해당 Topic 으로 데이터를 publish 한다
  • 처리 실패시 재시도한다.
Share