Если я создаю простую топологию, в которой у меня есть источник и процессор, я получаю удвоенный ожидаемый StreamThread в консолях.
Например, если я установил потоки в один и у меня есть один раздел, я вижу 2 потоковых потока. Если у меня установлено 20 потоков и 20 разделов, я вижу 40 потоковых потоков.
На основе номера потока Kafka Streams я ожидал половину этих чисел.
Я что-то настраиваю неправильно или это ожидается?
EDIT:
После потока = новый KafkaStreams (топология, streamsConfig); называется, я вижу только создать 20 потоков.
После вызова stream.start () я вижу, как эти 20 потоков переходят из CREATED в RUNNING.
Только в процессе инициализации создаются остальные 20 потоков. Похоже, что затем вызывается StreamsBuilderFactoryBean # start (), где в топологии ничего нет. Похоже, мне нужно либо как-то помешать этому вызову, либо удалить процесс создания. Не уверен, что является предпочтительным.