Package io.smallrye.reactive.messaging.kafka

Interface Summary

Interface	Description
DeserializationFailureHandler<T>	Bean invoked on Kafka deserialization failure.
IncomingKafkaCloudEventMetadata<K,T>	Addition "extension" attribute specific to incoming Kafka record
KafkaConsumerRebalanceListener	When implemented by a managed bean annotated with Named and configured against an inbound connector will be applied as a consumer re-balance listener to that inbound connector's consumer.
KafkaMessage<K,T>	Deprecated. Use instead
KafkaMessageMetadata<K>
KafkaRecord<K,T>

Class Summary

Class	Description
IncomingKafkaRecord<K,T>
IncomingKafkaRecordMetadata<K,T>
KafkaCDIEvents
KafkaConnector
KafkaConnectorCommonConfiguration	Extracts the common configuration for the smallrye-kafka connector.
KafkaConnectorIncomingConfiguration	Extract the incoming configuration for the smallrye-kafka connector.
KafkaConnectorOutgoingConfiguration	Extract the outgoing configuration for the smallrye-kafka connector.
OutgoingKafkaRecord<K,T>
OutgoingKafkaRecordMetadata<K>
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>
Record<K,V>	Represents a produced Kafka record, so a pair {key, value}.