我正在考虑使用apachekafka，但找不到任何关于持久订阅的信息。假设分区中的消息有5秒的过期时间。现在，如果消费者出现故障并在5秒后重新连接，他错过的消息将消失。更糟的是，他不知道他错过了一个信息。持久订阅模式通过为失败或断开连接的使用者保存消息来解决此问题。Kafka也有类似的功能吗？
w8ntj3qf1#
Kafka对此并不支持。但您当然可以增加保留时间，从而限制使用者错过消息的可能性。此外，如果你 auto.offset.reset 至 none 如果消费者遗漏了任何消息，您将得到一个异常通知。因此，如果发生这种情况，有可能得到通知。最后但并非最不重要的一点是，使用 compacted topic——这将确保在显式编写所谓的tombstone消息之前不会删除消息。请注意，记录必须具有唯一键才能使用压缩主题。
auto.offset.reset
none
compacted
1条答案
按热度按时间w8ntj3qf1#
Kafka对此并不支持。但您当然可以增加保留时间，从而限制使用者错过消息的可能性。
此外，如果你
auto.offset.reset至none如果消费者遗漏了任何消息，您将得到一个异常通知。因此，如果发生这种情况，有可能得到通知。最后但并非最不重要的一点是，使用
compactedtopic——这将确保在显式编写所谓的tombstone消息之前不会删除消息。请注意，记录必须具有唯一键才能使用压缩主题。