Hi All, After moving to kafka-streams-2.5.1 version, one of our services started failing with below exception. Any idea what this is about and why it was passing with 2.5.0? Any changes made in 2.5.1 that is breaking this?
Exception in thread "main" 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. at org.springframework.context.support.DefaultLifecycleProcessor.doStart( DefaultLifecycleProcessor.java:185 <http://defaultlifecycleprocessor.java:185/>) at org.springframework.context.support.DefaultLifecycleProcessor.access$200( DefaultLifecycleProcessor.java:53 <http://defaultlifecycleprocessor.java:53/>) at org.springframework.context.support .DefaultLifecycleProcessor$LifecycleGroup.start( DefaultLifecycleProcessor.java:360 <http://defaultlifecycleprocessor.java:360/>) at org.springframework.context.support.DefaultLifecycleProcessor.startBeans( DefaultLifecycleProcessor.java:158 <http://defaultlifecycleprocessor.java:158/>) at org.springframework.context.support.DefaultLifecycleProcessor.onRefresh( DefaultLifecycleProcessor.java:122 <http://defaultlifecycleprocessor.java:122/>) at org.springframework.context.support .AbstractApplicationContext.finishRefresh( AbstractApplicationContext.java:895 <http://abstractapplicationcontext.java:895/>) at org.springframework.context.support.AbstractApplicationContext.refresh( AbstractApplicationContext.java:554 <http://abstractapplicationcontext.java:554/>) at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh( ServletWebServerApplicationContext.java:143 <http://servletwebserverapplicationcontext.java:143/>) at org.springframework.boot.SpringApplication.refresh( SpringApplication.java:758 <http://springapplication.java:758/>) at org.springframework.boot.SpringApplication.refresh( SpringApplication.java:750 <http://springapplication.java:750/>) at org.springframework.boot.SpringApplication.refreshContext( SpringApplication.java:397 <http://springapplication.java:397/>) at org.springframework.boot.SpringApplication.run <http://org.springframework.boot.springapplication.run/>( SpringApplication.java:315 <http://springapplication.java:315/>) at org.springframework.boot.SpringApplication.run <http://org.springframework.boot.springapplication.run/>( SpringApplication.java:1237 <http://springapplication.java:1237/>) at org.springframework.boot.SpringApplication.run <http://org.springframework.boot.springapplication.run/>( SpringApplication.java:1226 <http://springapplication.java:1226/>) at com.avaya.analytics.AnalyticsStreamsDataPublisherApplication.main( AnalyticsStreamsDataPublisherApplication.java:31 <http://analyticsstreamsdatapublisherapplication.java:31/>) Caused by: 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. at org.springframework.kafka.config.StreamsBuilderFactoryBean.start( StreamsBuilderFactoryBean.java:326 <http://streamsbuilderfactorybean.java:326/>) at org.springframework.context.support.DefaultLifecycleProcessor.doStart( DefaultLifecycleProcessor.java:182 <http://defaultlifecycleprocessor.java:182/>) ... 14 more Caused by: 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. at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:728 <http://kafkastreams.java:728/>) at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:587 <http://kafkastreams.java:587/>) at org.springframework.kafka.config.StreamsBuilderFactoryBean.start( StreamsBuilderFactoryBean.java:311 <http://streamsbuilderfactorybean.java:311/>) ... 15 more
