我正在尝试开发一个使用库
我有一个配置类,构建了一个
好的...现在呢?使用不太反应灵敏的
那么
我正在使用Spring Boot 2.1.3和Reactor-Kafka 1.1.0。
提前致谢。
reactor-kafka
的Spring Boot应用程序,以响应从Kafka主题读取的一些消息。我有一个配置类,构建了一个
KafkaReceiver
。@Configuration
public class MyConfiguration {
@Bean
public KafkaReceiver<String, String> kafkaReceiver() {
Map<String, Object> props = new HashMap<>();
// Options initialisation...
final ReceiverOptions<String, String> receiverOptions =
ReceiverOptions.<String, string>create(props)
.subscription(Collections.singleton(consumer.getTopic()));
return KafkaReceiver.create(receiverOptions);
}
}
好的...现在呢?使用不太反应灵敏的
spring-kafka
库,我可以使用@KafkaListener
注释一个方法,Spring Boot将为我创建一个从Kafka主题监听的线程。那么
KafkaReceiver
应该放在哪里?在我找到的所有示例中,它们直接使用main
方法,但这不是Boot way。我正在使用Spring Boot 2.1.3和Reactor-Kafka 1.1.0。
提前致谢。