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

org.apache.kafka.clients.consumer.Consumer<K,V> kafkaConsumer

consumerRecord

org.apache.kafka.clients.consumer.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

org.apache.kafka.streams.KafkaStreams kafkaStreams

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

Serialized Fields

streams

org.apache.kafka.streams.kstream.KStream<K,V>[] streams

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

Serialized Fields

streams

org.apache.kafka.streams.kstream.KStream<K,V>[] streams