[CAMEL-17367] Kafka endpoint DSL for producer doesn't strip //

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 3.12.0, 3.14.0
• Fix Version/s: 3.14.1, 3.15.0
• Component/s: camel-endpointdsl, camel-kafka
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Andrew Rosenberg
• Created: 21/Dec/21 20:02
• Updated: 09/Jan/22 10:55
• Resolved: 09/Jan/22 10:54

Description

I'm trying something like this

.toD(
{{ kafka("my-topic")}}
{{ .brokers("kafka.brokers")}}
{{ .partitioner(org.apache.kafka.clients.producer.RoundRobinPartitioner.class.getName())}}
{{ .valueSerializer(ByteArraySerializer.class.getName()))}}

and I get this error

Metadata response reported invalid topics //my-topic

This is because parseTopicName in KafkaSendDynamicAware is unaware of the // in the uri.