Skip to content

Instantly share code, notes, and snippets.

@maheshwarLigade

maheshwarLigade/GreetMessageClient.java

Created July 23, 2020 10:43
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save maheshwarLigade/c7b092671e7761daac707f874872f000 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save maheshwarLigade/c7b092671e7761daac707f874872f000 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. maheshwarLigade created this gist Jul 23, 2020.
    14 changes: 14 additions & 0 deletions GreetMessageClient.java
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,14 @@
    package com.techwasti.kafkaex;

    import io.micronaut.configuration.kafka.annotation.KafkaClient;
    import io.micronaut.configuration.kafka.annotation.KafkaKey;
    import io.micronaut.configuration.kafka.annotation.Topic;

    @KafkaClient
    public interface GreetMessageClient {

    // greet is a kafka topic
    void sendGreetMessage(@KafkaKey String day, String message);

    void sendGreetMessage(@Topic String topic, @KafkaKey String day, String message);
    }