如何在 Kafka 低级处理器 API 中确定会话超时 ms

Question

所以假设标点符号时间为X分钟/秒

{
props.put("group.max.session.timeout.ms", X*2);
props.put("session.timeout.ms", x);
props.put("request.timeout.ms", X*2);
}

以上是为 Kafka 流低级处理器 API 设置会话超时的正确方法吗？

Answer 1

• group.max.session.timeout.ms是代理设置(参见 http://kafka.apache.org/documentation/#brokerconfigs
• 对于 Stream 中的使用者设置，建议使用前缀 consumer. ： props.put("consumer.session.timeout.ms", X)
• 您应该将max.poll.interval.ms设置为 Integer.MAX_VALUE(Streams 也会将其默认值更改为 Integer.MAX_VALUE (