我正在為我的api使用kafka。我正在使用帶有微服務的 spring 我將在下面發布我的 kafka 代碼：
命令：
private static final Logger logger =
LoggerFactory.getLogger(UserCommandServiceImpl.class);
@Autowired
private KafkaTemplate<String, Object> kafkaTemplate;
public void sendMessage(User objeto)
{
logger.info(String.format("Message sent -> %s", objeto.toString()));
this.kafkaTemplate.send("quickstart-events", objeto);
}
詢問：
private final Logger logger = LoggerFactory.getLogger(UserQueryServiceImpl.class);
@Autowired
private MongoTemplate mongoTemplate;
@KafkaListener(topics = "quickstart-events" , groupId = "group-id")
public void consume(String message)
{
logger.info(String.format("Message recieved -> %s", message));
mongoTemplate.insert(message, "user");
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/gongcheng/516956.html
標籤：弹簧靴阿帕奇卡夫卡
下一篇：錯誤的個人資料處于活動狀態