是否需要运行后台作业(job)来持续消费卡夫卡主题中的消息？
我try 在Kotlin中使用Kafka Kafka Consumer编写一个应用程序，有没有办法在不运行后台作业(job)的情况下使用来自Kafka的消息？
是否需要运行后台作业(job)来持续消费卡夫卡主题中的消息？
我try 在Kotlin中使用Kafka Kafka Consumer编写一个应用程序，有没有办法在不运行后台作业(job)的情况下使用来自Kafka的消息？
您不需要自己执行后台工作.把这件事留给框架吧.
您所需要做的就是将一个Micronaut Bean定义为KafkaListener.这documentation个国家如下:
使用@KafkaListener注释，Micronaut将构建一个KafkaConsumer，并通过在特殊的使用者线程池中运行KafkaConsumer来启动轮询循环
所以你应该做的是
@KafkaListener
class MyKafkaListener {
@Topic("topic-you-want-to-listen-to")
fun receive(@KafkaKey brand: String, name: String) {
// implement your listener
}
}
希望这能作为一个简短的澄清而有所帮助.