在新的Kafka Consumer API versions >0.9中,consumer.timeout.ms属性被session.timeout.ms属性取代。
session.timeout.ms属性定义了消费者与Kafka集群之间的会话超时时间。当消费者无法及时发送心跳到Kafka集群时,会被认为已经失去与集群的连接。如果在session.timeout.ms时间内没有发送心跳,Kafka集群将会将该消费者标记为失效,并将其分区重新分配给其他消费者。
session.timeout.ms属性的默认值为10秒,可以根据实际需求进行调整。较小的值可以使集群更快地检测到消费者故障,但也会增加误判的可能性。较大的值可以提供更长的恢复时间,但也会延迟故障的检测和重新分配分区的时间。
推荐的腾讯云相关产品是TDMQ(消息队列服务),它是腾讯云提供的一种高性能、高可靠、可弹性伸缩的消息队列服务。TDMQ基于Kafka协议,提供了丰富的特性和功能,适用于各种消息场景,包括实时数据处理、日志收集、事件驱动等。您可以通过访问以下链接了解更多关于TDMQ的信息:
https://cloud.tencent.com/product/tdmq
领取专属 10元无门槛券
手把手带您无忧上云