我用kafka作为我的api，我用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");

}

我从site安装了Kafka：我正在使用CQRS模式，所以每个查询都是一个微服务，并命令另一个。我的问题很简单，为每个微服务我创建了一个Kafka主题？谢谢！