测试flume、kafka 组件遇到的几个问题

1.flume采用netcat的方式测试服务是否正常启动的异常：
ERROR .apache.flume.source.NetcatSource - Unable to bind to socket. Exception follows.
java.net.BindException: Address already in use

原因：flume中的source设置的端口被占用 换一个端口即可
2…启动kafka的生产者时，发送消息失败的异常
Connection to node -1 could not be established. Broker may not be available. (.apache.kafka.clients.NetworkClient)

消费者可以正常启动
./kafka-console-consumer.sh --topic mytopic --zookeeper localhost:2181

错误的方式：./kafka-console-producer.sh --topic mytopic --broker-list localhost:9092 生产者能够正常启动但是不能发送数据

解决办法：将listeners设置为：PLAINTEXT://192.168.3.102:9092
误区：即使将生产者和地址都改为localhost也不能解决问题，即使修改zookeeper中的地址也是无效
可能是 因为hosts的原因，生产者只能ip启动
ip可以是主机中的任何一个，消费者可以用localhost启动