목록2019/07/16 (2)
khstar
kafka를 사용하려면 zookeeper를 반드시 사용해야 합니다. kafka를 설치하게 되면 기본적으로 zookeeper가 같이 설치 됩니다. config/zookeeper.properties에 설정만 해서 사용하면 되는데요. 전 kafka에 기본으로 설치된 zookeeper의 log 파일이 어디 생성되는지 어디를 설정해야 하는지 찾지 못해 별도로 zookeeper를 설치하였습니다. zookeeper를 실행하고 kafka를 실행하는데 log에 WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) java.net.C..
kafka를 설치하고 실행했는데 실행은 잘 된다. 그런데 topic을 생성하려는데 Replication factor: 1 larger than available brokers: 0. 오류가 발생한다. 다양한 이유가 있는듯 합니다. 전 server.properties의 설정이 잘못되어 발생했습니다. server.properties의 zookeeper.connect 값을 잘못 설정한겁니다. ㅜㅜ zookeeper.connect=master:2181/kafka-test, slave1:2181/kafka-test 이렇게요. 저 kafka-test는 왜 붙였던건지도 기억이 안나네요. zookeeper.connect=master:2181, slave1:2181 이렇게 바꿔서 다시 실행하고 topic을 생성하니 잘 ..