一次kafka producer沒有close引發的思考

       這個問題研究了兩天，最後被一句話點醒。在此記錄一下整個問題的思考過程。        在上一篇博客中實現了一個Avro序列化器http://www.javashuo.com/article/p-ryttkpho-b.html，但是在實現的過程中producer裏使用send(record)這種最簡單的方式發送消息時一直沒有在topic中讀取到這條消息（現在依舊可以看到上一篇中prod

>>阅读原文<<