问题描述
本人有个项目kafka集群只有一台服务器(不像正常的有三台,由于各种原因,只能提供一台)。有一个java web项目往kafka推消息。当kafka服务挂了后直接不可用,使web项目消息积压变得非常卡,我一旦重启web,就会导致消息没掉了。
问题出现的环境背景及自己尝试过哪些方法
这种情况是否需要在发送kafka失败后把数据本地先存下来,不用继续尝试?或者有其他解决办法?
8 回答2.6k 阅读
2 回答5.1k 阅读✓ 已解决
5 回答914 阅读
3 回答2.2k 阅读
1 回答806 阅读✓ 已解决
2 回答733 阅读✓ 已解决
3 回答1.8k 阅读
消费端做好幂等。