Quarkus Reactive Messaging - broadcast incoming kafka messages to websocket

[PanayiotisMilios]

Hello,

I've implemented an application that consumes kafka messages from a topic and broadcasts them to web-clients that are connected to my app with websocket.

In my KafkaConsumer class, I'm injecting my WebSocketServer object and in my @Incoming method that consumes the Kafka messages, I'm calling a broadcast method that i've implemented in the WebSocketServer to send the message to all connected clients.

My broadcast method looks like this:

public void broadcast(String message) {
      for (ServerWebSocket client : connectedClients) {
          client.writeTextMessage(message);
      }
  }

And my Kafka consuming method looks like this

@Incoming("kafka-topic")
  public void consume(String message) {
      webSocketServer.broadcast(message);
  }

I'm very new to the reactive concept and thus my question is whether what i'm doing defeats the whole purpose of reactive? Will the broadcast method block the event pool of threads. Is there any way to improve my implementation?

[quarkus-bot[bot]]

/cc @alesj (kafka), @cescoffier (kafka,reactive-messaging), @ozangunalp (kafka,reactive-messaging)