我有一个使用spring-kafka和kafka-streams的Java Spring Boot应用程序. 我正在try 构建GraalVM本机映像,
mvn -Pnative spring-boot:build-image
构建成功,但当我try 在docker中运行映像时,出现异常:
Caused by: org.apache.kafka.common.config.ConfigException: Invalid value org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier for configuration default.client.supplier: Class org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier could not be found.
at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:747)
at org.apache.kafka.common.config.ConfigDef$ConfigKey.<init>(ConfigDef.java:1175)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:155)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:175)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:214)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:376)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:389)
at org.apache.kafka.streams.StreamsConfig.<clinit>(StreamsConfig.java:1008)
... 16 common frames omitted
卡夫卡配置:
spring:
kafka:
producer:
value-serializer: "org.springframework.kafka.support.serializer.JsonSerializer"
properties:
spring:
json:
type:
mapping: "ErrorReportDomain:com.kt.kafka.messagingprocessor.domain.ErrorReportDomain"
client-id: messaging-processor
bootstrap-servers:
- "XXX"
security:
protocol: SASL_PLAINTEXT
properties:
sasl:
mechanism: SCRAM-SHA-512
jaas:
config: org.apache.kafka.common.security.scram.ScramLoginModule required username="XXX" password="XXX";
streams:
application.id: messaging-processor
properties:
spring:
json:
trusted:
packages: '*'
default:
key:
serde: org.apache.kafka.common.serialization.Serdes$StringSerde
value:
serde: org.springframework.kafka.support.serializer.JsonSerde
有什么建议吗?