Kafka¶
快速开始¶
下载¶
wget http://apache.forsale.plus/kafka/0.10.1.0/kafka_2.11-0.10.1.0.tgz
tar xf kafka_2.11-0.10.1.0.tgz -C /opt/
ln -s /opt/kafka_2.11-0.10.1.0/ /opt/kafka
cd /opt/kafka
mkdir /data/zookeeper
echo 2 > /data/zookeeper/myid
root@ubuntu75:/opt/kafka# bin/zookeeper-server-start.sh config/zookeeper.properties &[
root@ubuntu191:/opt/kafka# bin/zookeeper-server-start.sh config/zookeeper.properties &
root@ubuntu75:/opt/kafka# bin/kafka-server-start.sh config/server.properties &
报错信息¶
[2017-02-10 11:50:44,222] ERROR Setting LearnerType to PARTICIPANT but 3 not in QuorumPeers. (org.apache.zookeeper.server.quorum.QuorumPeer) [2017-02-10 11:50:44,226] INFO currentEpoch not found! Creating with a reasonable default of 0. This should only happen when you are upgrading your installation (org.apache.zookeeper.server.quorum.QuorumPeer) [2017-02-10 11:50:44,239] INFO acceptedEpoch not found! Creating with a reasonable default of 0. This should only happen when you are upgrading your installation (org.apache.zookeeper.server.quorum.QuorumPeer) [2017-02-10 11:50:44,253] ERROR Unexpected exception, exiting abnormally (org.apache.zookeeper.server.quorum.QuorumPeerMain) java.lang.RuntimeException: My id 3 not in the peer list
root@ubuntu75:/opt/kafka# grep -vE “#|^$” config/zookeeper.properties dataDir=/data/zookeeper clientPort=2181 tickTime=2000 initLimit=20 syncLimit=10 server.1=10.174.217.111:2888:3888 server.2=10.174.214.247:2888:3888
说明: server后面的数字,写入到 cat /data/zookeeper/myid 由于配置文件里面没有3,所以报上述错误