当我使用repo kafka-quickstart时，我注意到如果我在通道名称中添加句号，quarkus将无法启动。github repo中的通道名称是'quotes'，我将其更改为'quotes'。所有的事件。
属性文件条目更改为
mp.messaging.outgoing.quotes.ch.value.serializer = io.quarkus.kafka.client.serialization.ObjectMapperSerializer
通道名称为"quotes.ch"在QuotesProcessor以及带有"quotes.ch"在QuotesResource
处理器应用程序启动失败，出现以下异常::如何在quarkus中处理这些名称?
线程[39m [38;5;188m) [39m [38;5; 151m启动应用程序失败(与profile dev) [39m [38;5;203m: java.lang.IllegalArgumentException: SRMSG00071:无效通道配置-必须为通道quotes设置connector属性在io.smallrye.reactive.messaging.providers.impl.ConnectorConfig.lambda新0美元(ConnectorConfig.java: 50)在java.base/java.util.Optional.orElseThrow (Optional.java: 403)在io.smallrye.reactive.messaging.providers.impl.ConnectorConfig.lambda新1美元(ConnectorConfig.java: 50)在java.base/java.util.Optional.orElseGet (Optional.java: 364)在io.smallrye.reactive.messaging.providers.impl.ConnectorConfig。(ConnectorConfig.java: 49)在io.smallrye.reactive.messaging.providers.impl.ConfiguredChannelFactory.lambda extractConfigurationFor 0美元(ConfiguredChannelFactory.java: 85)在java.base/java.lang.Iterable.forEach (Iterable.java: 75)io.smallrye.reactive.messaging.providers.impl.ConfiguredChannelFactory.extractConfigurationFor (ConfiguredChannelFactory.java: 74)
更新:::这个问题/错误在https://github.com/quarkusio/quarkus/pull/25490
修复您需要更新您的应用程序。像this
这样的属性# Configurazione incoming quotes Kafka topic for Channel
mp.messaging.incoming.quotes.connector=smallrye-kafka
mp.messaging.incoming.quotes.topic=quotes
mp.messaging.incoming.quotes.auto.offset.reset=earliest
在正确配置kafka后，可以使用
@Channel("quotes")...
官方文档:您的用例的更多信息请访问https://quarkus.io/guides/kafka-reactive-getting-started还有另外一个例子https://quarkus.io/blog/getting-started-kafka/