如何在 Kafka 低级处理器中确定会话超时 ms API
How to decide session time out ms in Kafka low level processor API
所以假设标点时间是X min/sec
{
props.put("group.max.session.timeout.ms", X*2);
props.put("session.timeout.ms", x);
props.put("request.timeout.ms", X*2);
}
以上是为 Kafka 流低级处理器设置会话超时的正确方法吗API？
group.max.session.timeout.ms 是代理设置（参见 http://kafka.apache.org/documentation/#brokerconfigs- 对于 Streams 中的消费者设置，建议使用前缀
consumer.：props.put("consumer.session.timeout.ms", X)
- 您应该将
max.poll.interval.ms 设置为 Integer.MAX_VALUE（Streams 也会将此默认值更改为 Integer.MAX_VALUE）
所以假设标点时间是X min/sec
{
props.put("group.max.session.timeout.ms", X*2);
props.put("session.timeout.ms", x);
props.put("request.timeout.ms", X*2);
}
以上是为 Kafka 流低级处理器设置会话超时的正确方法吗API？
group.max.session.timeout.ms是代理设置（参见 http://kafka.apache.org/documentation/#brokerconfigs- 对于 Streams 中的消费者设置，建议使用前缀
consumer.：props.put("consumer.session.timeout.ms", X) - 您应该将
max.poll.interval.ms设置为Integer.MAX_VALUE（Streams 也会将此默认值更改为Integer.MAX_VALUE）