FooEventKafkaClient

FooEventKafkaClient.java

package com.foo.event.client;

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

@KafkaClient(id = "foo-kafka-client")
public interface FooEventKafkaClient {

    void publishEvent(@Topic String topic, @KafkaKey final String key, final Foo foo);
}