Исключение ниже выдается при изменении баланса.Мне интересно, является ли это проблемой определения объема бобов.Насколько я понимаю, все процессоры (и их зависимости) должны быть собственными экземплярами.Поэтому я определил все эти компоненты с помощью ConfigurableBeanFactory.SCOPE_PROTOTYPE.Это правильно?Есть ли другие примеры, которые не должны быть синглетонами при определении топологии?
Что еще может привести к тому, что AnnotationConfigEmbeddedWebApplicationContext уже закрыт для вызова.
Ошибка, обнаруженная при назначении раздела, приведет к прерыванию текущего процесса и повторному выбрасыванию в конце перебалансировки.
org.apache.kafka.streams.errors.StreamsException: stream-thread [rater-broker-e4a0027c-e2ce-493d-8b26-81d6edf1c275-StreamThread-2] Не удалось восстановить баланс.
Причинаby: java.lang.IllegalStateException: org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@6d868997 уже закрыт