如题,求教在 Rails 项目中使用 kafka 时消费消息是否有什么好办法。
我本人了解过 poseidon 和 posidon_cluster 这 2 个 gem,poseidon 对于生产消息支持良好,但是对于消费消息支持有限。 poseidon_cluster 对于消费消息支持比 poseidon 好一些,但是使用 fetch_loop 方法的话,默认情况下会在超时没有收到新消息会抛出异常, 这样就需要有监控重启进程的机制。
想了解下是否有人在实际项目中用到了 kafka,如果有消费消息的话,有什么经验教训可以分享下吗? 多谢~