먼저 zookeeper 서버를 실행한다.
$./bin/zookeeper-server-start.sh config/zookeeper.properties
kafka 서버를 실행한다. 최소 3대
$ ./bin/kafka-server-start.sh config/server-1.properties
$ ./bin/kafka-server-start.sh config/server-2.properties
$ ./bin/kafka-server-start.sh config/server-3.properties
각 설정 파일에 순서대로 설정을 변경한다.
listeners=PLAINTEXT://:포트
broker.id=아이디
log.dirs=/tmp/kafka-logs_파일번호
토픽을 생성한다.
$./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
만약 토픽 생성시 에러가 발생했다면 카프카 서버가 없어서 발생할 수 있다.
Error while executing topic command : replication factor: 1 larger than available brokers: 0
[2017-09-14 17:10:04,315] ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException: replication factor: 1 larger than available brokers: 0
(kafka.admin.TopicCommand$)
실제 데이터 입력한다.
$ ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
bin/kafka-console-consumer.sh --bootstrap-server localhost:9093 --topic test
'kafka' 카테고리의 다른 글
[kafka] inter.broker.protocol.version, log.message.format.version (0) | 2017.11.03 |
---|---|
kafka monitor에서 kafka 0.10.0.*를 지원한다. (0) | 2017.09.27 |
[kafka] 복제(replication) (0) | 2017.03.17 |
[kafka] 0.10.1.1 사용하면서 api 사용시 ProducerConfig와 ConsumerConfig를 잘 참조한다 (0) | 2017.03.16 |
[kafka] 구축 사례 - linkedin, uber, twitter, spotify, yahoo (0) | 2017.03.13 |