kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pushkar Deole <pdeole2...@gmail.com>
Subject started getting TopologyException: Invalid topology after moving to streams-2.5.1
Date Mon, 05 Oct 2020 09:34:05 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message