EurekaClient @Qualifier("eurekaClient") @Autowired private EurekaClient eurekaClient; public String
storm是grovvy写的kafka是scala写的storm-kafka storm连接kafka consumer的插件下载地址：https://github.com/wurstme
给接收端添加：channel.basic_qos(prefetch_count=1) ##一次处理一个，处理完再接受新消息发送端：import pika connec