小编n2m*_*2my的帖子

Spring Kafka 模板 - 在 Spring Boot 启动时连接到 Kafka 主题

我已经实现了一个使用 Spring Kafka 的基本 Spring Boot 应用程序。我希望我的制作人在第一个主题被调用之前连接到 Kafka 主题.send(),但我找不到方法来做到这一点。那可能吗?

日志显示 KafkaTemplate 仅在我触发以下.send方法后连接到 Kafka 主题16:12:44

2021-11-24 16:12:12.602  INFO 63930 --- [           main] c.e.k.KafkaProducerExampleApplication    : The following profiles are active: dev
2021-11-24 16:12:13.551  INFO 63930 --- [           main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat initialized with port(s): 8080 (http)
2021-11-24 16:12:13.559  INFO 63930 --- [           main] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
2021-11-24 16:12:13.559  INFO 63930 --- [           main] org.apache.catalina.core.StandardEngine  : Starting Servlet engine: [Apache Tomcat/9.0.53]
2021-11-24 16:12:13.613  INFO 63930 …
Run Code Online (Sandbox Code Playgroud)

java apache-kafka spring-kafka

2
推荐指数
1
解决办法
2203
查看次数

标签 统计

apache-kafka ×1

java ×1

spring-kafka ×1