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

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