天天看点

kafka踩过的坑

2019-03-20 16:33:37,787 [main] [kafka.producer.async.defaulteventhandler]-[debug] broker partitions registered for topic: ordermq are 0

2019-03-20 16:33:37,791 [main] [kafka.producer.async.defaulteventhandler]-[debug] sending 1 messages with no compression to [ordermq,0]

2019-03-20 16:33:37,798 [main] [kafka.producer.async.defaulteventhandler]-[debug] producer sending messages with correlation id 2 for topics [ordermq,0] to broker 0 on hadoop1:9092

2019-03-20 16:33:49,082 [main] [kafka.producer.syncproducer]-[error] producer connection to hadoop1:9092 unsuccessful

java.nio.channels.unresolvedaddressexception

    at sun.nio.ch.net.checkaddress(net.java:101)

    at sun.nio.ch.socketchannelimpl.connect(socketchannelimpl.java:622)

我是在window本地启动,测试linux的kafka集群,在网上找过一些解决方法 列如

但我实际上不是这个原因导致的,是由于我本地hosts中没有配置linux的kafka集群主机对应的ip,在hosts文件中配置所有集群的别名及对应的ip就可以正常启动了,hosts文件位置为c:\windows\system32\drivers\etc

kafka踩过的坑

error [replicafetcherthread-0-1], error for partition [flag_data_syc,1] to broker 1:class kafka.common.unknowntopicorpartitionexception (kafka.server.replicafetcherthread)

这个是我遇到的第二个问题,是由于我执行了删除topic操作但是没有完全删除,在我执行程序的时候就报错了

彻底删除topic,这个问题就能解决,topic路径,就是在你配置的config/server.properties中配置的,

kafka踩过的坑
kafka踩过的坑

 删除之后再执行程序就不会报错了