StreamsBuilderFactoryBean fails in a native image as org.apache.kafka.streams.errors.LogAndFailProcessingExceptionHandler cannot be loaded #3787
Description
In what version(s) of Spring for Apache Kafka are you seeing this issue?
Spring Kafka 3.3.4 with Apache Kafka 3.9.0
Describe the bug
2025-03-12T01:35:31.529Z WARN 3731 --- [ main] o.s.c.support.GenericApplicationContext : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'kafkaStreamsFunctionProcessorInvoker': Error creating bean with name 'stream-builder-process': null
Application run failed
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'kafkaStreamsFunctionProcessorInvoker': Error creating bean with name 'stream-builder-process': null
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1812)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:601)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:523)
at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:339)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:347)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:337)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:202)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.instantiateSingleton(DefaultListableBeanFactory.java:1155)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingleton(DefaultListableBeanFactory.java:1121)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:1056)
at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:987)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:627)
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:752)
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:439)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:318)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1361)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1350)
at com.example.cloud.stream.kafka.streams.SpringCloudStreamKafkaStreamsApplication.main(SpringCloudStreamKafkaStreamsApplication.java:42)
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'stream-builder-process': null
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1812)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:601)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:523)
at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:339)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:347)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:337)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:207)
at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1278)
at org.springframework.cloud.stream.binder.kafka.streams.AbstractKafkaStreamsBinderProcessor.buildStreamsBuilderAndRetrieveConfig(AbstractKafkaStreamsBinderProcessor.java:352)
at org.springframework.cloud.stream.binder.kafka.streams.KafkaStreamsFunctionProcessor.adaptAndRetrieveInboundArguments(KafkaStreamsFunctionProcessor.java:525)
at org.springframework.cloud.stream.binder.kafka.streams.KafkaStreamsFunctionProcessor.setupFunctionInvokerForKafkaStreams(KafkaStreamsFunctionProcessor.java:281)
at org.springframework.cloud.stream.binder.kafka.streams.function.KafkaStreamsFunctionProcessorInvoker.lambda$invoke$6(KafkaStreamsFunctionProcessorInvoker.java:95)
at [email protected]/java.util.Optional.ifPresent(Optional.java:178)
at org.springframework.cloud.stream.binder.kafka.streams.function.KafkaStreamsFunctionProcessorInvoker.invoke(KafkaStreamsFunctionProcessorInvoker.java:94)
at [email protected]/java.lang.reflect.Method.invoke(Method.java:569)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeCustomInitMethod(AbstractAutowireCapableBeanFactory.java:1916)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1869)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1808)
... 17 more
Caused by: java.lang.ExceptionInInitializerError
at org.springframework.kafka.config.StreamsBuilderFactoryBean.createStreamBuilder(StreamsBuilderFactoryBean.java:454)
at org.springframework.kafka.config.StreamsBuilderFactoryBean.createInstance(StreamsBuilderFactoryBean.java:335)
at org.springframework.kafka.config.StreamsBuilderFactoryBean.createInstance(StreamsBuilderFactoryBean.java:68)
at org.springframework.beans.factory.config.AbstractFactoryBean.afterPropertiesSet(AbstractFactoryBean.java:142)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1859)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1808)
... 34 more
Caused by: org.apache.kafka.common.config.ConfigException: Invalid value org.apache.kafka.streams.errors.LogAndFailProcessingExceptionHandler for configuration processing.exception.handler: Class org.apache.kafka.streams.errors.LogAndFailProcessingExceptionHandler could not be found.
at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:778)
at org.apache.kafka.common.config.ConfigDef$ConfigKey.<init>(ConfigDef.java:1271)
at org.apache.kafka.common.config.ConfigDef$ConfigKey.<init>(ConfigDef.java:1237)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:155)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:198)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:237)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:399)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:412)
at org.apache.kafka.streams.StreamsConfig.<clinit>(StreamsConfig.java:954)
... 40 more
To Reproduce
Run either cloud:cloud-stream-kafka-streams:nativeAppTest or integration:spring-kafka-streams:nativeAppTest in the main branch of the AOT smoke tests.
Expected behavior
The tests pass in a native image.
Sample
See the AOT smoke tests.