我在用 commitSync() 在Kafka的信息处理之后。我想知道有多少时间 commitSync() 在引发错误之前尝试提交？如果它给出了一个错误，那么同一条消息会在以后再次被轮询还是被假定为已被使用？
commitSync()
eh57zj3b1#
如果不指定超时， commitSync() 在指定的持续时间内阻塞 default.api.timeout.ms . 默认情况下为60秒。如果失败，该使用者示例将不会再次轮询相同的消息，它正在考虑使用。但是，如果该使用者示例崩溃，则使用同一使用者组的新示例将从上次成功提交的位置重新启动。
default.api.timeout.ms
1条答案
按热度按时间eh57zj3b1#
如果不指定超时，
commitSync()在指定的持续时间内阻塞default.api.timeout.ms. 默认情况下为60秒。如果失败，该使用者示例将不会再次轮询相同的消息，它正在考虑使用。
但是，如果该使用者示例崩溃，则使用同一使用者组的新示例将从上次成功提交的位置重新启动。