Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
@ApplicationScoped
public class ExampleBean {
@Incoming("from-kafka")
public void broadcast(String payload) {
System.out.println("Kafka says: " + payload);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment