最近一段时间，在尝试使用heka读取本机的日志文件，向kafka集群发送日志消息

具体的方式是，kafka使用单broker用来功能验证，heka使用自带的kafka插件，hekad的配置如下

[LogstreamerInput]

log_directory = "/data1/www/logs"

file_match = 'recom\.i\.weibo\.com-access_log'

[PayloadEncoder]

append_newlines = false

[FxaKafkaOutput]

type = "KafkaOutput"

message_matcher = "TRUE"

topic = "recom_i"

addrs = ["10.75.5.27:9092"]

encoder = "PayloadEncoder"

启动hekad，hekad -config="/etc/hekad.toml"

会报错，说连不上broker，而broker这个时候明明是好的，看了一下heka的kafka这个plugin的code，其实配置里addrs这个数组是直接传给了kafka的golang客户端sarama，因此转而看了看sarama的客户端，恍然大悟，原来在heka和broker开始建立通信的时候使用ip是没有问题的，但是sarama里面是通过broker去访问kafka依赖的zookeeper，进而从zookeeper里的metadata里面获取到了10.75.5.27这个机器的host是talus27，在接下来的向kafka的broker发布消息的通信中，由于无法解析talus27这个hostname而报发送失败

解决的办法很简单，在heka的机器的/etc/hosts文件中添加一行

10.75.5.27   talus27

就搞定了~