'Kafka Channel name with a 'period' in Quarkus application

While I am playing with repo kafka-quickstart , I noticed that if I add a period to the channel name quarkus is failing to start. The channel name in the github repo is 'quotes' and I changed it to 'quotes.ch' all over the occurrences.

the properties file entry is changed to
mp.messaging.outgoing.quotes.ch.value.serializer=io.quarkus.kafka.client.serialization.ObjectMapperSerializer
The outgoing annotation with channel name "quotes.ch" in QuotesProcessor and the channel annotation with "quotes.ch" in QuotesResource

The processor application failed to start with below exception :: How to handle such names in quarkus?

Thread [39m [38;5;188m) [39m [38;5;151mFailed to start application (with profile dev) [39m [38;5;203m: java.lang.IllegalArgumentException: SRMSG00071: Invalid channel configuration - the connector attribute must be set for channel quotes at io.smallrye.reactive.messaging.providers.impl.ConnectorConfig.lambda$new$0(ConnectorConfig.java:50) at java.base/java.util.Optional.orElseThrow(Optional.java:403) at io.smallrye.reactive.messaging.providers.impl.ConnectorConfig.lambda$new$1(ConnectorConfig.java:50) at java.base/java.util.Optional.orElseGet(Optional.java:364) at io.smallrye.reactive.messaging.providers.impl.ConnectorConfig.(ConnectorConfig.java:49) at io.smallrye.reactive.messaging.providers.impl.ConfiguredChannelFactory.lambda$extractConfigurationFor$0(ConfiguredChannelFactory.java:85) at java.base/java.lang.Iterable.forEach(Iterable.java:75) at io.smallrye.reactive.messaging.providers.impl.ConfiguredChannelFactory.extractConfigurationFor(ConfiguredChannelFactory.java:74)



Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source