1.環境說明

[[email protected] soft]# hostname

test1

[[email protected] soft]# cat /etc/hosts

127.0.0.1   localhost localhost.localdomain localhost4 localhost4.localdomain4

::1         localhost localhost.localdomain localhost6 localhost6.localdomain6

192.168.56.91 test1 

192.168.56.92 test2 
 

192.168.56.93 test3 

192.168.56.1  PC-201306171517

[[email protected] soft]# cat /etc/redhat-release 

CentOS release 6.4 (Final)

[[email protected] soft]# uname -a

Linux test1 2.6.32-358.el6.x86_64 #1 SMP Fri Feb 22 00:31:26 UTC 2013 x86_64 x86_64 x86_64 GNU/Linux
 

2.下載kafka

3.安裝配置kafka

一.解壓縮kafka

1

[[email protected] soft]# tar zxvf kafka_2.11-0.10.0.1.tgz -C /root/kafka

二.配置zookeeper

[
 
[email protected] config]# cat zookeeper.properties 

# Licensed to the Apache Software Foundation (ASF) under one or more

# contributor license agreements.  See the NOTICE file distributed with

# this work for additional information regarding copyright ownership.

# The ASF licenses this file to You under the Apache License, Version 2.0

# (the "License"); you may not use this file except in compliance with

# the License.  You may obtain a copy of the License at

# 

#    http://www.apache.org/licenses/LICENSE-2.0

# 

# Unless required by applicable law or agreed to in writing, software

# distributed under the License is distributed on an "AS IS" BASIS,

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

# See the License for the specific language governing permissions and

# limitations under the License.

# the directory where the snapshot is stored.

dataDir=/root/kafka/kafka_2.11-0.10.0.1/zoodata                       ###########這裡修改zookeeper的快照目錄,需要事先在檔案系統上建立目錄,其它預設即可.

# the port at which the clients will connect

clientPort=2181        #預設埠號2181

# disable the per-ip limit on the number of connections since this is a non-production config

maxClientCnxns=0

三.配置kafka

[[email protected] config]# pwd

/root/kafka/kafka_2.11-0.10.0.1/config

[[email protected] config]# cat server.properties 

# Licensed to the Apache Software Foundation (ASF) under one or more

# contributor license agreements.  See the NOTICE file distributed with

# this work for additional information regarding copyright ownership.

# The ASF licenses this file to You under the Apache License, Version 2.0

# (the "License"); you may not use this file except in compliance with

# the License.  You may obtain a copy of the License at

#

#    http://www.apache.org/licenses/LICENSE-2.0

#

# Unless required by applicable law or agreed to in writing, software

# distributed under the License is distributed on an "AS IS" BASIS,

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

# See the License for the specific language governing permissions and

# limitations under the License.

# see kafka.server.KafkaConfig for additional details and defaults

############################# Server Basics #############################

# The id of the broker. This must be set to a unique integer for each broker.

broker.id=0                                                                                    ############################這裡是主機的id,類似於zookeeper的id