Reactive Messaging codestart (in java and kotlin)

[ia3andy]

Description

Create a codestart for Reactive Messaging in java and kotlin

Implementation ideas

It's better to first discuss the content of the codestart here.

The goal is to have code:

• that is re-used 90% of the time to get started with the extension (nearly no deletion, renaming is fine)
• that is compatible with all other compatible extensions codestarts

What is the piece of code that you nearly always start with when using the extension.. Make it compile, and it's the perfect codestart!

The guide to create an extension codestart quarkus.io/guides/extension-codestart

[quarkus-bot]

/cc @cescoffier, @evanchooly, @michalszynkiewicz, @ozangunalp, @phillip-kruger, @quarkusio/devtools

[ia3andy]

@cescoffier suggested this:
(WARNING PSEUDO CODE - DO NOT COPY AND PASTE AND EXECUTE)

@ApplicationScoped
public class MyKafkaApplication {

    @Channel("my-kafka-topic") Emitter<String> emitter;

   /** Sends message to Kafka, can be used from a JAX-RS resource or  any bean of your application **/
  public void sendToKafka(String message) { emitter.send(message); }

 /** Consume from Kafka topic **/
@Incoming("from-kafka") void consume(String message) {
    Systme.out.println("Received: " + message);
}

}

[ia3andy]

@loicmathieu suggested this: "I will also add a processor as it's very common and it will show the @Outgoing annotation."

[vgallet]

I'm taking care of it ;-)

[ia3andy]

I am keeping @ozangunalp as reviewer/collaborator wdyt?

[ia3andy]

ok sorry, I managed to add you both as assignee :) GH was acting weird..