Skip navigation links
Reactor Kafka
A C D E G H M O P R S T 

A

acknowledge() - Method in interface reactor.kafka.receiver.ReceiverOffset
Acknowledges the ReceiverRecord associated with this offset.
addAssignListener(Consumer<Collection<ReceiverPartition>>) - Method in class reactor.kafka.receiver.ReceiverOptions
Adds a listener for partition assignments.
addRevokeListener(Consumer<Collection<ReceiverPartition>>) - Method in class reactor.kafka.receiver.ReceiverOptions
Adds a listener for partition revocations.
assignListeners() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns list of configured partition assignment listeners.
assignment(Collection<TopicPartition>) - Method in class reactor.kafka.receiver.ReceiverOptions
Sets subscription using manual assignment to the specified partitions.
assignment() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns the collection of partitions to be assigned if this instance is configured for manual partition assignment.
atmostOnceCommitAheadSize() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns the maximum difference between the offset committed for at-most-once delivery and the offset of the last record dispatched.
atmostOnceCommitAheadSize(int) - Method in class reactor.kafka.receiver.ReceiverOptions
Configures commit ahead size per partition for at-most-once delivery.

C

clearAssignListeners() - Method in class reactor.kafka.receiver.ReceiverOptions
Removes all partition assignment listeners.
clearRevokeListeners() - Method in class reactor.kafka.receiver.ReceiverOptions
Removes all partition revocation listeners.
close() - Method in interface reactor.kafka.sender.Sender
Closes this sender and the underlying Kafka producer and releases all resources allocated to it.
closeTimeout() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns timeout for graceful shutdown of KafkaConsumer.
closeTimeout(Duration) - Method in class reactor.kafka.receiver.ReceiverOptions
Sets timeout for graceful shutdown of KafkaConsumer.
closeTimeout() - Method in class reactor.kafka.sender.SenderOptions
Returns the timeout for graceful shutdown of this sender.
closeTimeout(Duration) - Method in class reactor.kafka.sender.SenderOptions
Configures the timeout for graceful shutdown of this sender.
commit() - Method in interface reactor.kafka.receiver.ReceiverOffset
Acknowledges the record associated with this instance and commits all acknowledged offsets.
commitBatchSize() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns the configured commit batch size for automatic commits of acknowledged records.
commitBatchSize(int) - Method in class reactor.kafka.receiver.ReceiverOptions
Configures commit batch size for automatic commits.
commitInterval() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns the configured commit interval for automatic commits of acknowledged records.
commitInterval(Duration) - Method in class reactor.kafka.receiver.ReceiverOptions
Configures commit interval for automatic commits.
consumerProperties() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns the configuration properties of the underlying KafkaConsumer.
consumerProperty(String) - Method in class reactor.kafka.receiver.ReceiverOptions
Returns the KafkaConsumer configuration property value for the specified option name.
consumerProperty(String, Object) - Method in class reactor.kafka.receiver.ReceiverOptions
Sets KafkaConsumer configuration property to the specified value.
correlationMetadata() - Method in class reactor.kafka.sender.SenderRecord
Returns the correlation metadata associated with this instance which is not sent to Kafka, but can be used to correlate response to outbound request.
correlationMetadata() - Method in interface reactor.kafka.sender.SenderResult
Returns the correlation metadata associated with this instance to enable this result to be matched with the corresponding SenderRecord that was sent to Kafka.
create(ReceiverOptions<K, V>) - Static method in interface reactor.kafka.receiver.Receiver
Creates a reactive Kafka receiver with the specified configuration options.
create() - Static method in class reactor.kafka.receiver.ReceiverOptions
Creates an options instance with default properties.
create(Map<String, Object>) - Static method in class reactor.kafka.receiver.ReceiverOptions
Creates an options instance with the specified config overrides for KafkaConsumer.
create(Properties) - Static method in class reactor.kafka.receiver.ReceiverOptions
Creates an options instance with the specified config overrides for KafkaConsumer.
create(SenderOptions<K, V>) - Static method in interface reactor.kafka.sender.Sender
Creates a Kafka sender that appends records to Kafka topic partitions.
create() - Static method in class reactor.kafka.sender.SenderOptions
Creates a sender options instance with default properties.
create(Map<String, Object>) - Static method in class reactor.kafka.sender.SenderOptions
Creates a sender options instance with the specified config overrides for the underlying Kafka Producer.
create(Properties) - Static method in class reactor.kafka.sender.SenderOptions
Creates a sender options instance with the specified config overrides for the underlying Kafka Producer.
create(ProducerRecord<K, V>, T) - Static method in class reactor.kafka.sender.SenderRecord
Creates a record to send to Kafka.

D

doOnConsumer(Function<Consumer<K, V>, ? extends T>) - Method in interface reactor.kafka.receiver.Receiver
Invokes the specified function on the Kafka Consumer associated with this Receiver.
doOnProducer(Function<Producer<K, V>, ? extends T>) - Method in interface reactor.kafka.sender.Sender
Invokes the specified function on the Kafka Producer associated with this Sender.

E

exception() - Method in interface reactor.kafka.sender.SenderResult
Returns the exception associated with a send failure.

G

groupId() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns the configured Kafka consumer group id.

H

heartbeatInterval() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns the configured heartbeat interval for Kafka consumer.

M

maxCommitAttempts() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns the maximum number of consecutive non-fatal commit failures that are tolerated.
maxCommitAttempts(int) - Method in class reactor.kafka.receiver.ReceiverOptions
Configures the maximum number of consecutive non-fatal RetriableCommitFailedException commit failures that are tolerated.
maxInFlight() - Method in class reactor.kafka.sender.SenderOptions
Returns the maximum number of in-flight records that are fetched from the outbound record publisher while acknowledgements are pending.
maxInFlight(int) - Method in class reactor.kafka.sender.SenderOptions
Configures the maximum number of in-flight records that are fetched from the outbound record publisher while acknowledgements are pending.

O

offset() - Method in interface reactor.kafka.receiver.ReceiverOffset
Returns the partition offset corresponding to the record to which this instance is associated.
offset() - Method in interface reactor.kafka.receiver.ReceiverRecord
Returns an acknowledgeable offset instance that should be acknowledged after this record has been consumed.

P

pollTimeout() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns the timeout for each KafkaConsumer.poll(long) operation.
pollTimeout(Duration) - Method in class reactor.kafka.receiver.ReceiverOptions
Sets the timeout for each KafkaConsumer.poll(long) operation.
position() - Method in interface reactor.kafka.receiver.ReceiverPartition
Returns the offset of the next record that will be fetched from this topic partition.
producerProperties() - Method in class reactor.kafka.sender.SenderOptions
Returns the configuration properties for the underlying Kafka Producer.
producerProperty(String) - Method in class reactor.kafka.sender.SenderOptions
Returns the Kafka Producer configuration property value for the specified option name.
producerProperty(String, Object) - Method in class reactor.kafka.sender.SenderOptions
Sets Kafka Producer configuration property to the specified value.

R

reactor.kafka.receiver - package reactor.kafka.receiver
Reactor Kafka Receiver API
reactor.kafka.sender - package reactor.kafka.sender
Reactor Kafka Sender API
receive() - Method in interface reactor.kafka.receiver.Receiver
Starts a Kafka consumer that consumes records from the subscriptions or partition assignments configured for this receiver.
receiveAtmostOnce() - Method in interface reactor.kafka.receiver.Receiver
Returns a Flux of consumer records that are committed before the record is dispatched to provide atmost-once delivery semantics.
receiveAutoAck() - Method in interface reactor.kafka.receiver.Receiver
Returns a Flux containing each batch of consumer records returned by Consumer.poll(long).
Receiver<K,V> - Interface in reactor.kafka.receiver
A reactive Kafka receiver for consuming records from topic partitions of a Kafka cluster.
ReceiverOffset - Interface in reactor.kafka.receiver
Topic partition offset that must be acknowledged after the record in the corresponding ReceiverRecord is processed.
ReceiverOptions<K,V> - Class in reactor.kafka.receiver
Configuration properties for Reactive Kafka Receiver and its underlying KafkaConsumer.
ReceiverPartition - Interface in reactor.kafka.receiver
Topic partition interface that supports seek operations that can be invoked when partitions are assigned.
ReceiverRecord<K,V> - Interface in reactor.kafka.receiver
Represents an incoming record dispatched by Receiver.
record() - Method in interface reactor.kafka.receiver.ReceiverRecord
Returns the Kafka consumer record associated with this instance.
record() - Method in class reactor.kafka.sender.SenderRecord
Returns the Kafka producer record associated with this instance.
recordMetadata() - Method in interface reactor.kafka.sender.SenderResult
Returns the record metadata returned by Kafka.
revokeListeners() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns list of configured partition revocation listeners.

S

scheduler() - Method in class reactor.kafka.sender.SenderOptions
Returns the scheduler used for publishing send results.
scheduler(Scheduler) - Method in class reactor.kafka.sender.SenderOptions
Sets the scheduler used for publishing send results.
seek(long) - Method in interface reactor.kafka.receiver.ReceiverPartition
Seeks to the specified offset of the topic partition.
seekToBeginning() - Method in interface reactor.kafka.receiver.ReceiverPartition
Seeks to the first available offset of the topic partition.
seekToEnd() - Method in interface reactor.kafka.receiver.ReceiverPartition
Seeks to the last offset of the topic partition.
send(Publisher<SenderRecord<K, V, T>>, boolean) - Method in interface reactor.kafka.sender.Sender
Sends a sequence of records to Kafka and returns a Flux of response record metadata including partition and offset of each send request.
send(Publisher<ProducerRecord<K, V>>) - Method in interface reactor.kafka.sender.Sender
Sends a sequence of producer records to Kafka.
Sender<K,V> - Interface in reactor.kafka.sender
Reactive producer that sends outgoing records to topic partitions of a Kafka cluster.
SenderOptions<K,V> - Class in reactor.kafka.sender
Configuration properties for reactive Kafka Sender and its underlying Kafka Producer.
SenderRecord<K,V,T> - Class in reactor.kafka.sender
Represents an outgoing record.
SenderResult<T> - Interface in reactor.kafka.sender
Result metadata for an outbound record that was acknowledged by Kafka.
subscriber(ConsumerRebalanceListener) - Method in class reactor.kafka.receiver.ReceiverOptions
Returns the KafkaConsumer.subscribe(Collection, ConsumerRebalanceListener), KafkaConsumer.subscribe(Pattern, ConsumerRebalanceListener) or KafkaConsumer.assign(Collection) operation corresponding to the subscription or assignment options configured for this instance.
subscription(Collection<String>) - Method in class reactor.kafka.receiver.ReceiverOptions
Sets subscription using group management to the specified collection of topics.
subscription(Pattern) - Method in class reactor.kafka.receiver.ReceiverOptions
Sets subscription using group management to the specified pattern.

T

toImmutable() - Method in class reactor.kafka.receiver.ReceiverOptions
Returns a new immutable instance with the configuration properties of this instance.
toImmutable() - Method in class reactor.kafka.sender.SenderOptions
Returns a new immutable instance with the configuration properties of this instance.
topicPartition() - Method in interface reactor.kafka.receiver.ReceiverOffset
Returns the topic partition corresponding to this instance.
topicPartition() - Method in interface reactor.kafka.receiver.ReceiverPartition
Returns the underlying Kafka topic partition.
A C D E G H M O P R S T 
Skip navigation links
Reactor Kafka