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

spring:
  kafka:
    bootstrap-servers: localhost:9092  # Kafka服務(wù)器地址
    consumer:
      group-id: my-group              # 消費(fèi)者組ID
      auto-offset-reset: earliest     # 消費(fèi)者偏移重置方式
      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主題名稱(chēng)，根據(jù)實(shí)際需求修改
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;
    public void sendMessage(String message) {
        kafkaTemplate.send(TOPIC, message); // 發(fā)送消息到Kafka主題
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class UserService {
    @Autowired
    private KafkaProducerService kafkaProducerService;
    // 假設(shè)用戶(hù)數(shù)據(jù)更新時(shí)調(diào)用該方法
    public void updateUser(User user) {
        // 執(zhí)行用戶(hù)數(shù)據(jù)更新邏輯
        // ...
        // 發(fā)送消息到Kafka通知其他廠商
        kafkaProducerService.sendMessage("User updated: " + user.getId());
    }
}