micronaut-kafka icon indicating copy to clipboard operation
micronaut-kafka copied to clipboard

Unconfigured/unused default kafka stream causes an invalid topology

Open drmaas opened this issue 5 years ago • 2 comments

When using only @Named streams, micronaut-kafka-streams does not run.

19:10:40.966 [main] ERROR io.micronaut.runtime.Micronaut - Error starting Micronaut server: Bean definition [org.apache.kafka.streams.KafkaStreams] could not be loaded: Error instantiating bean of type [org.apache.kafka.streams.KafkaStreams]: Invalid topology: Topology has no stream threads and no global threads, must subscribe to at least one source topic or global table.

Example using micronaut 2.2.0, micronaut-kafka-streams 3.1.0, and kafka-streams 2.6.0: https://github.com/drmaas/micronaut-kafka-issue

See https://github.com/micronaut-projects/micronaut-kafka/issues/196 for reference.

drmaas avatar Dec 03 '20 01:12 drmaas

I think this affects all versions..

I mentioned this bug in this comment.. https://github.com/micronaut-projects/micronaut-kafka/issues/139#issuecomment-688956724

geemanjs avatar Dec 04 '20 15:12 geemanjs

Running into the same issue, we can't disable the Kafka streams health check

mcanalesmayo avatar Jan 04 '21 04:01 mcanalesmayo

I've been trying to reproduce this issue with the latest versions of the libraries and the problem seems to be solved at the present time. I can update the source code and the continuous build execution works flawlessly.

There used to be some KAPT bugs related to incremental processing that were corrected in the past. These bugfixes could be related to the problem you reported:

Since this issue was opened a long time ago and the problem is solved in current releases, I will close it now. Please feel free to raise a new one if you encounter this issue again.

guillermocalvo avatar Aug 25 '23 10:08 guillermocalvo