Kafka是否可以监控消费者的心跳，并通过在队列中持久化来重试作业（最终将其发送给不同的消费者）？我也知道SQL表可以用作队列，但你能让我知道其他选项吗？
bjp0bcyl1#
如果我对这个问题的理解是正确的，那么Kafka主题是持久的。如果你使用消费者组和提交偏移量，那么当组的消费者重新启动/加入时，它将在最后提交的偏移量处拾取，是的。如果那不可用，它将使用auto.offset.reset配置位置或者你可以禁用基于Kafka的提交，并在SQL数据库中存储偏移量，当然，但Kafka并不提供这一功能
auto.offset.reset
1条答案
按热度按时间bjp0bcyl1#
如果我对这个问题的理解是正确的，那么Kafka主题是持久的。如果你使用消费者组和提交偏移量，那么当组的消费者重新启动/加入时，它将在最后提交的偏移量处拾取，是的。如果那不可用，它将使用
auto.offset.reset配置位置或者你可以禁用基于Kafka的提交，并在SQL数据库中存储偏移量，当然，但Kafka并不提供这一功能