立即注册 登录
About云-梭伦科技 返回首页

howtodown的个人空间 https://www.aboutyun.com/?19 [收藏] [复制] [分享] [RSS]

日志

apache kafka v0.8入门遇到问题

已有 947 次阅读2014-9-15 18:34

官方文档:https://kafka.apache.org/documentation.html

 

说下quick start遇到问题:

  • 运行kafka二进制项目不需要scala
  • 文档API栏目,每个API后面有example,字比较小,打开里面有示例

 

错误:

1. producer的配置只需要kafka server ip即可,但如果kafka server使用hostname作为zookeeper地址配置,那就需要在producer端配置zookeeper hostname与IP映射(hosts文件),否则会出现"kafka Failed to send messages after 3 tries”。producer启动log显示如下:


2014-01-27 16:01:20,405  INFO [Logging.scala:67] - <Fetching metadata from broker id:0,host:192.168.30.43,port:9092 with correlation id 0 for 1 topic(s) Set(test)>  

2014-01-27 16:01:20,416  INFO [Logging.scala:67] - <Connected to 192.168.30.43:9092 for producing>  

2014-01-27 16:01:20,468  INFO [Logging.scala:67] - <Disconnecting from 192.168.30.43:9092>  

2014-01-27 16:01:20,541  INFO [Logging.scala:67] - <Connected to h1:9092 for producing>  


 log 显示producter先连接kafka 服务端口9092获取metadata信息(如zookeeper信息),然后IP(192.168.30.43),就访问就变成通过h1这个hostname访问了,如果没有配置h1与ip映射就会出现问题。






路过

雷人

握手

鲜花

鸡蛋

评论 (0 个评论)

facelist doodle 涂鸦板

您需要登录后才可以评论 登录 | 立即注册

关闭

推荐上一条 /2 下一条