카프카 설치
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 한다
- 처리 실패시 재시도한다.