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
KafkaClientService
KafkaConsumer<K,V>	Kafka Consumer API.
KafkaConsumerRebalanceListener	When implemented by a managed bean annotated with @Identifier and configured against an inbound connector, it will be applied as a consumer rebalance 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}.