Serialized Form

Package io.micronaut.configuration.kafka.exceptions

Class io.micronaut.configuration.kafka.exceptions.KafkaListenerException extends io.micronaut.messaging.exceptions.MessageListenerException implements Serializable

Serialized Fields

listener

java.lang.Object listener

kafkaConsumer

Consumer<K,V> kafkaConsumer

consumerRecord

ConsumerRecord<K,V> consumerRecord

Package io.micronaut.configuration.kafka.streams.event

Class io.micronaut.configuration.kafka.streams.event.AbstractKafkaStreamsEvent extends io.micronaut.context.event.ApplicationEvent implements Serializable

Serialized Fields

kafkaStreams

KafkaStreams kafkaStreams

Class io.micronaut.configuration.kafka.streams.event.AfterKafkaStreamsStart extends AbstractKafkaStreamsEvent implements Serializable

Serialized Fields

streams

KStream<K,V>[] streams

Class io.micronaut.configuration.kafka.streams.event.BeforeKafkaStreamStart extends AbstractKafkaStreamsEvent implements Serializable

Serialized Fields

streams

KStream<K,V>[] streams