如何使用SpringBoot集成Kafka实现用户数据变更后发送消息

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

spring:
  kafka:
    bootstrap-servers: localhost:9092  # Kafka服务器地址
    consumer:
      group-id: my-group              # 消费者组ID
      auto-offset-reset: earliest     # 消费者偏移重置方式
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
    producer:
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;
@Service
public class KafkaProducerService {
    private static final String TOPIC = "user-events"; // Kafka主题名称，根据实际需求修改
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;
    public void sendMessage(String message) {
        kafkaTemplate.send(TOPIC, message); // 发送消息到Kafka主题
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class UserService {
    @Autowired
    private KafkaProducerService kafkaProducerService;
    // 假设用户数据更新时调用该方法
    public void updateUser(User user) {
        // 执行用户数据更新逻辑
        // ...
        // 发送消息到Kafka通知其他厂商
        kafkaProducerService.sendMessage("User updated: " + user.getId());
    }
}