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