要验证sprng kafka producer是否成功发送消息,可以采取以下步骤:
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>版本号</version>
</dependency>
spring.kafka.bootstrap-servers=Kafka服务器地址
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
@Autowired
private KafkaTemplate<String, String> kafkaTemplate;
public void sendMessage(String message) {
kafkaTemplate.send("主题名称", message);
}
kafkaTemplate.send("主题名称", message).addCallback(new ListenableFutureCallback<SendResult<String, String>>() {
@Override
public void onSuccess(SendResult<String, String> result) {
// 消息成功发送
System.out.println("消息发送成功:" + result.getRecordMetadata().toString());
}
@Override
public void onFailure(Throwable ex) {
// 消息发送失败
System.out.println("消息发送失败:" + ex.getMessage());
}
});
@KafkaListener(topics = "主题名称")
public void receiveMessage(String message) {
// 接收到消息
System.out.println("接收到消息:" + message);
}
通过以上步骤,可以验证sprng kafka producer是否成功发送消息。如果成功发送,可以通过回调函数得到发送结果;如果需要进一步验证,可以使用Kafka消费者来确认消息是否到达Kafka。
领取专属 10元无门槛券
手把手带您无忧上云