FooEventKafkaClient.java

FooEventKafkaClient.java

package com.company.project.event.client;

import com.company.project.event.v1.FooEvent;
import io.micronaut.configuration.kafka.annotation.KafkaClient;
import io.micronaut.configuration.kafka.annotation.KafkaKey;
import io.micronaut.configuration.kafka.annotation.Topic;
import io.micronaut.context.annotation.Requires;
import io.micronaut.retry.annotation.Retryable;

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

    @Topic("${topics.binding.foo.events.output:foo-topic}")
    void publishEvent(@KafkaKey final String eventKey, final FooEvent event);
}