zzl001 发表于 2017-1-6 12:25:10

apache kafka v0.8入门遇到问题

官方文档: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,405INFO - <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,416INFO - <Connected to 192.168.30.43:9092 for producing>
2014-01-27 16:01:20,468INFO - <Disconnecting from 192.168.30.43:9092>
2014-01-27 16:01:20,541INFO - <Connected to h1:9092 for producing>
  
  log 显示producter先连接kafka 服务端口9092获取metadata信息(如zookeeper信息),然后IP(192.168.30.43),就访问就变成通过h1这个hostname访问了,如果没有配置h1与ip映射就会出现问题。
  
  
  
  
页: [1]
查看完整版本: apache kafka v0.8入门遇到问题