Hi Pushkar, Sorry for the trouble. Can you share your config and topology description?
If I read your error message correctly, it says that your app is configured with no source topics and no threads. Is that accurate? Thanks, -John On Mon, 2020-10-05 at 15:04 +0530, Pushkar Deole wrote: > 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
