擼了今年阿里、頭條和美團的面試，我有一個重要發現.......>>>

kafka生產者生產30條數據，而消費者卻不一定消費了30條數據，經過探索發現了main線程執行完成了而kafka的數據并沒有發送完，而當main線程執行完成之后JVM就會關閉，那么那些異步的消息沒發送完成的也會因為jvm的關閉而丟失。而導致部分消費者沒有接收到消息。

kafkatemplate.flush()強制將緩沖區中的數據發送出去,不必等到緩沖區滿.

總結

以上是生活随笔為你收集整理的kafka生产者和消费者端的数据不一致的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。