Hi All,
I upgraded from Kafka streams 2.4 to 2.5.0 and one of the applications
suddenly stopped working with the error message:
Exception in thread
"DsiApplication-0fcde033-dab2-431c-9d82-76e85fcb4c91-StreamThread-1"
java.lang.IllegalStateException: Consumer is not subscribed to any topics
or assigned any partitions
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1228)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216)
at
org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:853)
at
org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:753)
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:697)
at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:670)
This application uses streams just to create a global state store from a
topic in order to create a global state store as a cache for static data
across application instances and the stream doesn't consume from any input
topic. Came across following thread on stackoverflow
https://stackoverflow.com/questions/61342530/kafka-streams-2-5-0-requires-input-topic
Matthias, I see you have answered some queries there, so would like to
confirm if setting num.stream.threads to 0 will solve this issue?
