标签：zookeeper kafka KAKFA 0.11 使用 server 安装 properties 2.11

HDFS正常启动

zookeeper正常安装

sw目录下的KAFKA解压安装

tar zxvf kafka_2.11-0.11.0.2.tgz

mv kafka_2.11-0.11.0.2   ../md/

配置环境变量

vi ~/.bash_profile

export KAFKA_HOME=/home/a/md/kafka_2.11-0.11.0.2

export PATH=$KAFKA_HOME/bin:$PATH

source ~/.bash_profile

cd ~/md/kafka_2.11-0.11.0.2/config/目录下，修改server.properties,这里要注意启动几个kafka就要配置几个server.properties

server.properties主要配置参数

broker.id=0   

delete.topic.enable=true  是否可以删除主题

listeners=PLAINTEXT://:9092  默认的端口，如果有多个的话，就要依次在每个server.properties中设置listeners=PLAINTEXT://:9092     server1.properties listeners=PLAINTEXT://:9093，server2.properties listeners=PLAINTEXT://:9094

log.dirs=/home/a/md/kafka_2.11-0.11.0.2/data1  为kafka要缓存的数据位置，

zookeeper.connect=master:12181/kafka0.11　　连接到zookeeper哪里，如果有多个zookeeper服务器都要以逗号隔开，全部写上。

kafka如何启动呢

启动第1个:kafka-server-start.sh -daemon ~/md/kafka_2.11-0.11.0.2/config/server1.properties

启动第2个:kafka-server-start.sh -daemon ~/md/kafka_2.11-0.11.0.2/config/server2.properties

...

如何查看kafka相关信息呢？

zkCli.sh -server master:12181

ls /

 

 

get  /kafka0.11/brokers/ids/0

 

 创建topic呢？

kafka-topics.sh --create -topic mykafka1 --zookeeper master:12181/kafka0.11 --partitions 3 --replication-factor 1

查看topic呢

kafka-topics.sh --list --zookeeper master:12181/kakfa0.11

删除topic

kafka-topic.sh --delete -topic  -zookeeper master:12181/kafka0.11

 

 

 通过zkCli.sh -server master:12181可以进行各种源信息的查询。

 

　配置producer 和cusumoer进行通信

　producer生产数据

　

　consumer接收数据

 

标签：zookeeper,kafka,KAKFA,0.11,使用,server,安装,properties,2.11
来源： https://www.cnblogs.com/BrentBoys/p/10802014.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。