为什么我会收到此日志 - 重置上次看到的纪元

Ole*_*lle 12 spring-kafka

我有一个 Spring Boot 应用程序,它将多个主题发送到 kafka。

在我用来发送的服务中,我已经自动连接了这个。

  private final KafkaTemplate<String, Object> kafkaTemplate;
Run Code Online (Sandbox Code Playgroud)

当我使用此 kafkaTemplate 发送到多个主题时,我会在日志中收到以下信息。

[Producer clientId= Producer-1] 由于关联的 topicId 从 null 更改为 J09iQeooQtOuAyEfntux_g,因此将分区 ***** 的最后一次看到的纪元重置为 87

发送。我创建了一个 GenericRecord

GenericRecord kafkaValue = new GenericData.Record(schema);
Run Code Online (Sandbox Code Playgroud)

然后我在 genericRecord 上设置值,准备好后我用这一行发送。

kafkaStringTemplate.send(new ProducerRecord<>(sendMessageConfiguration.getTopicName(), textKey, kafkaValue));
Run Code Online (Sandbox Code Playgroud)

这个警告重要吗?如果是的话我做错了什么?在我看来,所有消息都已发送。