Skip to content

Instantly share code, notes, and snippets.

@ctoestreich

ctoestreich/FooEventKafkaClient.java

Created March 15, 2020 01:16
Show Gist options
  • Save ctoestreich/7d1e1ecf41ce24156861ce610f9ebe73 to your computer and use it in GitHub Desktop.
Save ctoestreich/7d1e1ecf41ce24156861ce610f9ebe73 to your computer and use it in GitHub Desktop.
Download ZIP
FooEventKafkaClient
Raw
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);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment