Package io.smallrye.reactive.messaging.kafka

Class KafkaCDIEvents

java.lang.Object

io.smallrye.reactive.messaging.kafka.KafkaCDIEvents

@ApplicationScoped
public class KafkaCDIEvents
extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaCDIEvents()

Method Summary

Modifier and Type	Method	Description
javax.enterprise.event.Event<org.apache.kafka.clients.consumer.Consumer<?,?>>	consumer()
javax.enterprise.event.Event<org.apache.kafka.clients.producer.Producer<?,?>>	producer()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaCDIEvents

public KafkaCDIEvents()

Method Detail

consumer

public javax.enterprise.event.Event<org.apache.kafka.clients.consumer.Consumer<?,?>> consumer()

producer

public javax.enterprise.event.Event<org.apache.kafka.clients.producer.Producer<?,?>> producer()