PersonObjectClient.java

PersonObjectClient.java

package com.company.kafka.client;

import com.company.avro.PersonObject;
import io.micronaut.configuration.kafka.annotation.KafkaClient;
import io.micronaut.configuration.kafka.annotation.KafkaKey;
import io.micronaut.configuration.kafka.annotation.Topic;

@KafkaClient(id = "person-object-client")
public interface PersonObjectClient {

    String OUTPUT = "person-object-output";

    @Topic(OUTPUT)
    void publishEvent(@KafkaKey String eventKey, PersonObject personObject);
}