我有一个 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)
这个警告重要吗?如果是的话我做错了什么?在我看来,所有消息都已发送。
| 归档时间: |
|
| 查看次数: |
2104 次 |
| 最近记录: |