解决方案也很简单,设置
acks(消息确认机制)
retries(重试机制)
factor(设置 partition 数量)…