一次kafka producer没有close引发的思考

       这个问题研究了两天，最后被一句话点醒。在此记录一下整个问题的思考过程。        在上一篇博客中实现了一个Avro序列化器http://www.javashuo.com/article/p-ryttkpho-b.html，但是在实现的过程中producer里使用send(record)这种最简单的方式发送消息时一直没有在topic中读取到这条消息（现在依旧可以看到上一篇中prod

>>阅读原文<<