apache-kafka - 在 Apache Kafka 中，谁来填充 RecordMetadata 以及一旦生产者得到这些信息，这些信息将驻留在哪里？

Question

我正在进行一项测试，以了解如果 kafka 集群中的所有代理都关闭，生产者将如何反应。在此测试期间，我观察到我正在低于错误，因为 45000 毫秒是“max.block.ms”的值。

发送失败; 嵌套异常是 org.apache.kafka.common.errors.TimeoutException：45000 毫秒后元数据中不存在主题 test.topic

我相信这个元数据不过是RecordMetadata。现在我的问题是，谁来填充RecordMetadata以及一旦生产者得到这些信息，这些信息将驻留在哪里？

标签： apache-kafka

Answer 1

你没有记录，所以它实际上是主题元数据。

正如您对上一个问题的回答，如果您无法连接到引导地址，您将获得这些日志。

Zookeeper 持有主题元数据