当前位置:首页 > 开发 > 开源软件 > 正文

kafka安装

发表于: 2014-02-19   作者:aoyouzi   来源:转载   浏览次数:
摘要: 1、下载:http://kafka.apache.org/2、安装步骤:http://kafka.apache.org/documentation.html#quickstart没有按照上面的步骤执行./sbt修改 conf/server.propertieszookeeper.connect=192.168.27.101:2181broker.id分别改成broker.id=0host.name

1、下载:
http://kafka.apache.org/


2、安装步骤:
http://kafka.apache.org/documentation.html#quickstart


没有按照上面的步骤执行./sbt

修改 conf/server.properties

zookeeper.connect=192.168.27.101:2181

broker.id分别改成
broker.id=0
host.name分别改成(如果不改,client访问集群时,如果没在hosts配置对应机器的 hostname,访问将会报错)
host.name=192.168.27.101

可根据需求修改
port: broker节点使用端口号 默认 9092
log.dir: 消息目录位置


3. 启动Kafka
cd /usr/local/kafka_2.8.0-0.8.0
JMX_PORT=9999 bin/kafka-server-start.sh config/server.properties & (似乎是多个broker安装在同一机器需要指定JMX_PORT,这里可以不指定)

 

其中需要先启动zookeeper,zookeeper为安装storm时已安装


//启动报错Unrecognized VM option '+UseCompressedOops'
查看 bin/kafka-run-class.sh 
找到
if [ -z "$KAFKA_JVM_PERFORMANCE_OPTS" ]; then
  KAFKA_JVM_PERFORMANCE_OPTS="-server  -XX:+UseCompressedOops -XX:+UseParNewGC -XX:+UseConcMarkSweepGC -XX:+CMSClassUnloadingEnabled -XX:+CMSScavengeBeforeRemark -XX:+DisableExplicitGC -Djava.awt.headless=true"
fi

去掉-XX:+UseCompressedOops

 

4、测试
创建主题
bin/kafka-create-topic.sh --zookeeper 192.168.27.101:2181 --partition 1 --topic mytest
bin/kafka-list-topic.sh --zookeeper 192.168.27.101:2181


生产者,消费者测试 
bin/kafka-console-producer.sh --broker-list 192.168.27.101:9092 --topic mytest 
wo
yes


//输入命令后,输入字符串
bin/kafka-console-consumer.sh --zookeeper 192.168.27.101:2181 --topic mytest --from-beginning
wo
yes
//即回显示数据

kafka安装

  • 0

    开心

    开心

  • 0

    板砖

    板砖

  • 0

    感动

    感动

  • 0

    有用

    有用

  • 0

    疑问

    疑问

  • 0

    难过

    难过

  • 0

    无聊

    无聊

  • 0

    震惊

    震惊

编辑推荐
kafka安装 http://blog.csdn.net/weijonathan/article/details/18075967 http://blog.csdn.net/kimm
1. 简介 kafka (官网地址: http://kafka.apache.org)是一款分布式消息发布和订阅的系统,具有高性
1. 简介 kafka (官网地址: http://kafka.apache.org)是一款分布式消息发布和订阅的系统,具有高性
1. 简介 kafka (官网地址:http://kafka.apache.org)是一款分布式消息发布和订阅的系统,具有高性
1. 简介 kafka (官网地址: http://kafka.apache.org)是一款分布式消息发布和订阅的系统,具有高性
kafka是一种高吞吐量的分布式发布订阅消息系统,她有如下特性: 通过O(1)的磁盘数据结构提供消息的
1. 简介 kafka (官网地址: http://kafka.apache.org)是一款分布式消息发布和订阅的系统,具有高性
1. 简介 kafka (官网地址: http://kafka.apache.org)是一款分布式消息发布和订阅的系统,具有高性
9 kafka
【原创声明】本文属作者原创,已授权InfoQ中文站首发,转载请务必在文章开头标明出自“Jason's Blog
10 kafka
kafka设计原理介绍 背景介绍 Kafka简介   Kafka是一种分布式的,基于发布/订阅的消息系统。主要设
版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号