【问题标题】:Difference between connections.max.idle.ms and max.poll.interval.ms in Kafka configuration?Kafka配置中connections.max.idle.ms和max.poll.interval.ms的区别?
【发布时间】:2022-02-22 02:09:34
【问题描述】:

我也想知道,既然心跳请求是在Apache Kakfa Consumer中发送的,是否也会影响connections.max.idle.ms?

您如何处理 kafka-apache 客户端中的错误(生产者和消费者以及围绕它们的最佳实践)?

谢谢:]

【问题讨论】:

    标签: apache-kafka kafka-python


    【解决方案1】:

    空闲套接字超时在轮询和心跳连接上被重置,并且可以被认为是任何协议请求的上限

    如果空闲超时小于轮询间隔、会话超时或心跳间隔,那么您可能会看到一些网络连接断开

    【讨论】:

    • 感谢您的回复。只是为了澄清,您的意思是心跳请求将重置connections.max.idle.ms超时?如果可能的话,您是否还可以阐明生产中的错误处理 kafka,我看到 kafka-python 中的大多数异常都被抑制了,并且重新连接和重试都被烘焙了
    • 我不必使用该库在生产环境中编写 Python 客户端,因此我不确定是否会发现错误。显然,在处理您的记录时捕获任何错误......并且为消费者打开了多个连接,例如元数据请求、获取、心跳和提交。连接空闲超时应大于任何一个单独的超时/间隔,并且单独地,这些请求的连接空闲时间在它们发生时会被重置
    猜你喜欢
    • 2020-05-19
    • 1970-01-01
    • 2020-11-05
    • 2017-10-08
    • 2022-01-23
    • 2017-02-05
    • 2016-10-25
    • 1970-01-01
    • 2020-07-25
    相关资源
    最近更新 更多