[kafka0.10]kafka 서버를 단독으로 실행하는 방법

먼저 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