kafka系列教程

消息队列

#kafka系列教程

##安装配置

###1、安装配置
（1）、wget http://mirrors.cnnic.cn/apache/kafka/0.10.0.1/kafka_2.10-0.10.0.1.tgz 地址随时有可能改变 http://kafka.apache.org/downloads.html
(2)、tar -xzf kafka_2.10-0.10.0.1.tgz
(3)、export KAFKA_HOME=/usr/local/kafka…… 视自己情况而定
(4)、export PATH=$PATH:$KAFKA_HOME/bin

###2、启动
(1)、先启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
(2)、启动zookeeper后，稍微等一会（30秒）再启动kafka，否则出错
$KAFKA_HOME/bin/kafka-server-start.sh $KAFKA_HOME/config/server.properties &
(3)、创建一个kafka topic (名称是kafkatopic)
bin/kafka-topics.sh –create –zookeeper localhost:2181 –replication-factor 1 -partitions 1 –topic kafkatopic
(4)、列出topic
./bin/kafka-topics.sh –list –zookeeper localhost:2181

###开始发送消息
（1）、开启控制台发送消息
./bin/kafka-console-producer.sh –broker-list localhost:9092 –top
ic kafkatopic

###开启消费消息
（2）、开启控制台消费消息
./bin/kafka-console-consumer.sh –zookeeper localhost:2181 –topic
kafkatopic –from-beginning

##配置单机多代理模式（一台机器多个broker）

###配置
1、kafka的每一个server-1.properties文件需要区别3个配置项目，分别是 broker.id port log.dir
比如说默认配置是这样的：

  • brokder.id 1
  • port 9093
  • log.dir /tmp/kafka-logs-1
    加一个broker既可以单独配置一个server-2.properties
  • broker.id 2
  • prot 9094
  • log.dir /tmp/kafka-logs-2

2、OK,配置完成之后就可以用命令启动2个broker了
/bin/kafka-server-start.sh /config/server-1.properties
/bin/kafka-server-start.sh /config/server-1.properties

Share