4.项目配置或业务问题

发布时间:2025-06-24 17:10:51  作者:北方职教升学中心  阅读量:595


以获取元数据。:。ms。kafka。bootstrap-servers。.。

关于topicc的Kafka存储元数据、

1.问题原因。

翻译后:因为kafka制造商在发送消息时,topic元数据信息在指定时间内无法获得。common。
topic在同一节点的正常生产和消费也不是这个问题。

我检查了一些kafka的生产者配置 看下面的配置:

kafka。state。-。ms。所以这个没有问题。:。

:。.。我检查了一些kafka的生产者配置 看下面的配置:kafka。

2.问题排查。

这个参数意味着:

metadata.max.age.ms是kafka配置中的参数,用于指定元数据的最大生存时间(以毫秒为单位)。properties。KafkaException。 60000。failed。;nested exception is。127.0.0.1。errors。metadata。-。-。

1. 某个broker在Kafka集群中停机或不可用,无法获得topic的元数据信息。device。
检查集群监控󿀌每个节点都可以通过ping,

4.项目配置或业务问题。Send。:。.。如果元数据在一定时间内没有更新,然后它将过期并需要重新获得。:。.。broker等信息的数据结构。:。kafka。age。springframework。
这也不是,版本之前已经核对过了。producer。,它向集群中的每个broker发送请求,#连接地址。

org。topic not present in metadata after。max。向这个topic发送空数据,观察一天后󿀌正是因为这个原因。:。
300000。9092。.。:。.。.。:。:。:。 org。TimeoutException。

3.Kafka版不兼容󿀌无法获得topic的元数据信息。Topic。当客户端连接到Kafka集群时,apache。.。.。in。
我们每天生产一次这个topic󿀌其他topic在项目中几分钟一次或实时都没有问题,怀疑发送间隔是否太长,这个问题,我开始写一个5分钟的定时任务,

2. 网络连接不稳定或延迟过高c;无法及时获取topic的元数据信息。我把它设置成5分钟󿀌元数据在 metadata.max.age.ms 在规定的时间范围内没有更新,被迫更新,这个问题就解决了。partition、