Serialized Form

Package io.micronaut.configuration.kafka.exceptions

Exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException

class KafkaListenerException extends io.micronaut.messaging.exceptions.MessageListenerException implements Serializable

Serialized Fields

consumerRecord

ConsumerRecord<?,?> consumerRecord

kafkaConsumer

Consumer<?,?> kafkaConsumer

listener

Object listener

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

Class io.micronaut.configuration.kafka.streams.event.AbstractKafkaStreamsEvent

class AbstractKafkaStreamsEvent extends io.micronaut.context.event.ApplicationEvent implements Serializable

Serialized Fields

kafkaStreams

KafkaStreams kafkaStreams

Class io.micronaut.configuration.kafka.streams.event.AfterKafkaStreamsStart

class AfterKafkaStreamsStart extends AbstractKafkaStreamsEvent implements Serializable

Serialized Fields

streams

KStream<?,?>[] streams

Class io.micronaut.configuration.kafka.streams.event.BeforeKafkaStreamStart

class BeforeKafkaStreamStart extends AbstractKafkaStreamsEvent implements Serializable

Serialized Fields

streams

KStream<?,?>[] streams