Package io.smallrye.reactive.messaging.kafka

Interface Summary

Interface	Description
DeserializationFailureHandler<T>	Bean invoked on Kafka deserialization to implement custom failure handling.
IncomingKafkaCloudEventMetadata<K,T>	Addition "extension" attribute specific to incoming Kafka record
KafkaAdmin	Internal interface for Kafka admin client.
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>	Deprecated. use KafkaMessageMetadata instead
KafkaProducer<K,V>	Kafka Producer API.
KafkaRecord<K,T>
KafkaRecordBatch<K,T>	Represents a batch of Kafka records received by polling the KafkaConsumer This type extends the Message<List<T>> where T is the type of records' payloads.
SerializationFailureHandler<T>	Bean invoked on Kafka serialization failure.

Class Summary

Class	Description
IncomingKafkaRecord<K,T>
IncomingKafkaRecordBatch<K,T>
IncomingKafkaRecordMetadata<K,T>	Deprecated. use IncomingKafkaRecordMetadata instead
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>	Deprecated. use OutgoingKafkaRecordMetadata instead
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>
Record<K,V>	Represents a produced Kafka record, so a pair {key, value}.