微服务中kafka监听消费信息后在调用kafka下发数据给下游样例

好的，下面是一个简单的微服务中使用Kafka监听消费信息，并在收到消息后调用Kafka下发数据给下游的样例代码：

@Service
public class KafkaConsumerService {
    private static final Logger logger = LoggerFactory.getLogger(KafkaConsumerService.class);

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    @KafkaListener(topics = "${kafka.topic.consumer}")
    public void receiveMessage(String message) {
        logger.info("Received message: {}", message);
        // 在这里处理收到的消息
        // 下面是一个简单的例子，将收到的消息转为大写并发送给下游
        String upperCaseMessage = message.toUpperCase();
        kafkaTemplate.send("${kafka.topic.producer}", upperCaseMessage);
        logger.info("Sent message: {}", upperCaseMessage);
    }
}

上面的代码中，我们使用了Spring Kafka提供的`@KafkaListener`注解来监听指定topic的消息。当收到消息后，我们将其转为大写并使用`KafkaTemplate`发送到另一个topic中。其中`${kafka.topic.consumer}`和`${kafka.topic.producer}`是配置文件中定义的消费者和生产者的topic名称。

当然，这只是一个简单的样例，实际应用中还需要考虑消息的序列化和反序列化、消息的重试、消费者的分组以及消息的顺序等问题。