频道栏目
首页 > 程序开发 > 综合编程 > 其他综合 > 正文
zookeeper和kafka实践
2017-02-18 10:10:00           
收藏   我要投稿

zookeeper和kafka实践:1、使用kafka,依赖zookeeper和scala,对应版本从网上找。2、都安装完成后,进入kafka的安装路径下面的bin目录,打开。

存在这些文件

常用命令说明:

kafka-console-producer.sh(命令模式下发送消息)【./kafka-console-producer.sh--broker-list localhost:9092 --topic test】

kafka-console-consumer.sh(命令模式下消费消息)【./kafka-console-consumer.sh--zookeeper localhost:9092 --topic test --from-beginning】

kafka-server-start.sh(启动kafka)【./kafka-server-start.sh ../config/server.properties】

kafka-server-stop.sh(关闭kafka)

zookeeper-server-start.sh(启动zookeeper)【./zookeeper-server-start.sh ../config/zookeeper.properties】

zookeeper-server-stop.sh(关闭zookeeper)

3、接下来进入../config目录

常用说明:

server.properties(kafka服务配置,其中server1和server2是多个broker的配置文件)

zookeeper.properties(zookeeper的配置文件)

进入server.properties

 

说明:

host.name--->producer和consumer是通过这个主机名(advertised.host.name)来连接broker的,而如果这个值没有设置,则会使用上面的host.name的值,如果上面的host.name也没有设置,则会使用java.net.InetAddress.getCanonicalHostName()获取的值。从Zookeeper中可以看出,默认的时候该broker是localhost,从其他机器访问当然不可能成功。【解决Failed to send messages after 3 tries错误的方案】

zookeeper.connect--->zookeeper地址端口(最好都配成服务器的真实ip,不要localhost,不然程序里面不好调用)

以上配置完毕,接下来实例测试

1、命令:

①:启动zookeeper

②:启动kafka

③:producer发送消息

④:consumer消费消息

2、程序代码

定义生产者

topic:对应的主题

message:发送的消息

发送消息

接收到消息

至此,结束。

点击复制链接 与好友分享!回本站首页
上一篇:REST-RPC服务接口实例分析
下一篇:SVN需求文档的完善
相关文章
图文推荐
文章
推荐
点击排行

关于我们 | 联系我们 | 广告服务 | 投资合作 | 版权申明 | 在线帮助 | 网站地图 | 作品发布 | Vip技术培训 | 举报中心

版权所有: 红黑联盟--致力于做实用的IT技术学习网站