Matthias J. Sax created KAFKA-20869:
---------------------------------------
Summary: KafkaStreams#addStreamsThread crashed global-task-only
client
Key: KAFKA-20869
URL: https://issues.apache.org/jira/browse/KAFKA-20869
Project: Kafka
Issue Type: Bug
Components: streams
Reporter: Matthias J. Sax
KafkaStreams allows to run a "global only" topology. For this case,
`KafkaStreams#start()` won't spin up any StreamsThreads (independent of
`num.stream.threads` config) and only run the global-thread.
However, addStreamsThread() has not guard for this case, and if called would
create a new StreamThread which immediately crashes, taking down the whole
client (with the default uncaught exception handler).
It's even worse if the exception handler returns replace-thread, and we end up
in an infinite error-loop...
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
