Как настроить UncaughtExceptionHandlers для нескольких привязок в весенних потоках кафки?

Question

Сейчас я пытаюсь получить доступ к описателю основных потоков kafka, выполнив - https://cloud.spring.io/spring-cloud-static/Finchley.SR2/multi/multi__apache_kafka_streams_binder.html#_accessing_the_underlying_kafkastreams_object Интересно, есть ли более идиоматический способ сделать это? Особенно, когда есть скрепления муфлей.

Answer 1

Вы можете позвонить context.getBeansOfType(StreamsBuilderFactoryBean.class, false, false), чтобы получить карту beanName:factoryBean.

Однако вы должны быть осторожны, чтобы не делать это слишком рано в жизненном цикле контекста, поскольку вы можете вызвать преждевременную реализацию объекта.

Вероятно, лучше всего сделать это в SmartInitializingSingleton.