Reproducer for issue 50751

Author: mocenas

integration-tests/reactive-messaging-kafka/src/main/java/io/quarkus/it/kafka/MessageTransmitter.java

@@ -0,0 +1,19 @@
+package io.quarkus.it.kafka;
+
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
+
+import org.eclipse.microprofile.reactive.messaging.Channel;
+import org.eclipse.microprofile.reactive.messaging.Emitter;
+
+@ApplicationScoped
+public class MessageTransmitter {
+
+    @Inject
+    @Channel("foo.bar-topic")
+    Emitter<String> emitter;
+
+    public void emit(String message) {
+        emitter.send(message).toCompletableFuture().join();
+    }
+}

integration-tests/reactive-messaging-kafka/src/test/java/io/quarkus/it/kafka/TransmitterTest.java

@@ -0,0 +1,48 @@
+package io.quarkus.it.kafka;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+import java.time.Duration;
+import java.util.List;
+
+import jakarta.inject.Inject;
+
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.junit.jupiter.api.Tag;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.DisabledOnOs;
+import org.junit.jupiter.api.condition.OS;
+
+import io.quarkus.test.common.WithTestResource;
+import io.quarkus.test.junit.QuarkusTest;
+import io.quarkus.test.kafka.InjectKafkaCompanion;
+import io.quarkus.test.kafka.KafkaCompanionResource;
+import io.smallrye.reactive.messaging.kafka.companion.KafkaCompanion;
+
+@QuarkusTest
+@WithTestResource(KafkaCompanionResource.class)
+@DisabledOnOs({ OS.WINDOWS }) // Kafka requires docker to start
+@Tag("https://github.com/quarkusio/quarkus/issues/50751")
+class TransmitterTest {
+
+    @Inject
+    MessageTransmitter messageTransmitter;
+
+    @InjectKafkaCompanion
+    KafkaCompanion companion;
+
+    @Test
+    void dashedTopic() {
+        String message = "Hello, Quarkus!";
+        messageTransmitter.emit(message);
+
+        List<String> actual = companion.consumeStrings()
+                .fromTopics("foo.bar-topic")
+                .awaitRecords(1, Duration.ofSeconds(30))
+                .stream()
+                .map(ConsumerRecord::value)
+                .toList();
+        assertEquals(1, actual.size());
+        assertEquals(message, actual.get(0));
+    }
+}