Uses of Package
io.smallrye.reactive.messaging.kafka
-
Classes in io.smallrye.reactive.messaging.kafka used by acme Class Description KafkaRecord -
Classes in io.smallrye.reactive.messaging.kafka used by io.smallrye.reactive.messaging.kafka Class Description KafkaConnectorCommonConfiguration Extracts the common configuration for thesmallrye-kafkaconnector.KafkaConsumer Kafka Consumer API.KafkaMessageMetadata Deprecated.useKafkaMessageMetadatainsteadKafkaProducer Kafka Producer API.KafkaRecord KafkaRecordBatch Represents a batch of Kafka records received by polling theKafkaConsumerThis type extends theMessage<List<T>>whereTis the type of records' payloads.OutgoingKafkaRecord OutgoingKafkaRecordMetadata Deprecated.useOutgoingKafkaRecordMetadatainsteadOutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder Deprecated.Record Represents a produced Kafka record, so a pair {key, value}. -
Classes in io.smallrye.reactive.messaging.kafka used by io.smallrye.reactive.messaging.kafka.commit Class Description IncomingKafkaRecord KafkaConnectorIncomingConfiguration Extract the incoming configuration for thesmallrye-kafkaconnector. -
Classes in io.smallrye.reactive.messaging.kafka used by io.smallrye.reactive.messaging.kafka.fault Class Description DeserializationFailureHandler Bean invoked on Kafka deserialization to implement custom failure handling.IncomingKafkaRecord KafkaCDIEvents KafkaConnectorIncomingConfiguration Extract the incoming configuration for thesmallrye-kafkaconnector.SerializationFailureHandler Bean invoked on Kafka serialization failure. -
Classes in io.smallrye.reactive.messaging.kafka used by io.smallrye.reactive.messaging.kafka.health Class Description KafkaAdmin Internal interface for Kafka admin client.KafkaConnectorIncomingConfiguration Extract the incoming configuration for thesmallrye-kafkaconnector.KafkaConnectorOutgoingConfiguration Extract the outgoing configuration for thesmallrye-kafkaconnector. -
Classes in io.smallrye.reactive.messaging.kafka used by io.smallrye.reactive.messaging.kafka.impl Class Description IncomingKafkaRecord IncomingKafkaRecordBatch KafkaAdmin Internal interface for Kafka admin client.KafkaCDIEvents KafkaClientService KafkaConnectorIncomingConfiguration Extract the incoming configuration for thesmallrye-kafkaconnector.KafkaConnectorOutgoingConfiguration Extract the outgoing configuration for thesmallrye-kafkaconnector.KafkaConsumer Kafka Consumer API.KafkaConsumerRebalanceListener When implemented by a managed bean annotated with@Identifierand configured against an inbound connector, it will be applied as a consumer rebalance listener to that inbound connector's consumer.KafkaProducer Kafka Producer API.SerializationFailureHandler Bean invoked on Kafka serialization failure. -
Classes in io.smallrye.reactive.messaging.kafka used by io.smallrye.reactive.messaging.kafka.impl.ce Class Description IncomingKafkaCloudEventMetadata Addition "extension" attribute specific to incoming Kafka recordKafkaConnectorOutgoingConfiguration Extract the outgoing configuration for thesmallrye-kafkaconnector.