首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

在新的Kafka Consumer API versions >0.9中,哪个属性取代了consumer.timeout.ms?

在新的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

页面内容是否对你有帮助?
有帮助
没帮助

相关·内容

领券