Package io.smallrye.reactive.messaging.kafka
-
Interface Summary Interface Description KafkaMessage<K,T> Deprecated. Useinstead
KafkaMessageMetadata<K> KafkaRecord<K,T> -
Class Summary Class Description IncomingKafkaRecord<K,T> IncomingKafkaRecordMetadata<K,T> KafkaConnector KafkaConnectorCommonConfiguration Extracts the common configuration for thesmallrye-kafka
connector.KafkaConnectorIncomingConfiguration Extract the incoming configuration for thesmallrye-kafka
connector.KafkaConnectorOutgoingConfiguration Extract the outgoing configuration for thesmallrye-kafka
connector.OutgoingKafkaRecord<K,T> OutgoingKafkaRecordMetadata<K> OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>