springboot整合kafkastream无法启动

紫梦★幻殇 发表于: 2022-02-07   最后更新时间: 2022-02-07 23:14:55   1,592 游览

Topology with no input topics will create no stream threads and no global thread

2022-02-07 22:28:50.526 INFO 2374 --- [ main] org.apache.kafka.streams.KafkaStreams : stream-client [lingxi-63883365-744e-42c0-960b-5f0dbfa73a8a] Overriding number of StreamThreads to zero for global-only topology
2022-02-07 22:28:50.526 ERROR 2374 --- [ main] org.apache.kafka.streams.KafkaStreams : stream-client [lingxi-63883365-744e-42c0-960b-5f0dbfa73a8a] Topology with no input topics will create no stream threads and no global thread.
2022-02-07 22:28:50.527 WARN 2374 --- [ main] ConfigServletWebServerApplicationContext : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.context.ApplicationContextException: Failed to start bean 'defaultKafkaStreamsBuilder'; nested exception is org.springframework.kafka.KafkaException: Could not start stream: ; nested exception is org.apache.kafka.streams.errors.TopologyException: Invalid topology: Topology has no stream threads and no global threads, must subscribe to at least one source topic or global table.

发表于 2022-02-07
添加评论
你的答案

查看kafka相关的其他问题或提一个您自己的问题