io.smallrye.reactive.messaging.kafka.impl

Class ReactiveKafkaConsumer<K,V>

java.lang.Object

io.smallrye.reactive.messaging.kafka.impl.ReactiveKafkaConsumer<K,V>

All Implemented Interfaces:

KafkaConsumer<K,V>

public class ReactiveKafkaConsumer<K,V>
extends Object
implements KafkaConsumer<K,V>

Constructor Summary

Constructors

Constructor and Description
ReactiveKafkaConsumer(KafkaConnectorIncomingConfiguration config, KafkaSource<K,V> source)

Method Summary

Modifier and Type	Method and Description
void	close()
io.smallrye.mutiny.Uni<Void>	commit(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> map) Commits the offsets
io.smallrye.mutiny.Uni<Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>>	committed(org.apache.kafka.common.TopicPartition... tps) Retrieved the last committed offset for each topic/partition
Map<String,?>	configuration()
String	get(String attribute)
io.smallrye.mutiny.Uni<Set<org.apache.kafka.common.TopicPartition>>	getAssignments() Retrieves the current assignments of the consumer.
io.smallrye.mutiny.Uni<Map<org.apache.kafka.common.TopicPartition,Long>>	getPositions() Retrieves the next positions for each assigned topic/partitions
void	injectClient(org.apache.kafka.clients.consumer.MockConsumer<?,?> consumer)
io.smallrye.mutiny.Uni<Set<org.apache.kafka.common.TopicPartition>>	pause() Pauses the consumption of records.
io.smallrye.mutiny.Uni<Set<org.apache.kafka.common.TopicPartition>>	paused() Retrieves the set of paused topic/partition
io.smallrye.mutiny.Uni<Void>	resume() Resumes the consumption of record.
io.smallrye.mutiny.Uni<Void>	runOnPollingThread(Consumer<org.apache.kafka.clients.consumer.Consumer<K,V>> action) Runs an action on the polling thread.
<T> io.smallrye.mutiny.Uni<T>	runOnPollingThread(Function<org.apache.kafka.clients.consumer.Consumer<K,V>,T> action) Runs an action on the polling thread.
void	setRebalanceListener()
io.smallrye.mutiny.Multi<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>	subscribe(Pattern topics)
io.smallrye.mutiny.Multi<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>	subscribe(Set<String> topics)
org.apache.kafka.clients.consumer.Consumer<K,V>	unwrap()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReactiveKafkaConsumer

public ReactiveKafkaConsumer(KafkaConnectorIncomingConfiguration config,
                             KafkaSource<K,V> source)

Method Detail

setRebalanceListener

public void setRebalanceListener()

runOnPollingThread

public <T> io.smallrye.mutiny.Uni<T> runOnPollingThread(Function<org.apache.kafka.clients.consumer.Consumer<K,V>,T> action)

Description copied from interface: KafkaConsumer

Runs an action on the polling thread.

The action is a function taking as parameter the Consumer and that returns a result (potentially null). The produced Uni emits the returned result when the action completes. If the action throws an exception, the produced using emits the exception as failure.

If the action does not return a result, use KafkaConsumer.runOnPollingThread(Consumer).

Specified by:

runOnPollingThread in interface KafkaConsumer<K,V>

Type Parameters:

T - the type of result, can be Void

Parameters:

action - the action to execute, must not be null

Returns:

the Uni emitting the result or the failure when the action completes.

runOnPollingThread

public io.smallrye.mutiny.Uni<Void> runOnPollingThread(Consumer<org.apache.kafka.clients.consumer.Consumer<K,V>> action)

Description copied from interface: KafkaConsumer

Runs an action on the polling thread.

The action is a consumer receiving the Consumer. The produced Uni emits null when the action completes. If the action throws an exception, the produced using emits the exception as failure.

Specified by:

runOnPollingThread in interface KafkaConsumer<K,V>

Parameters:

action - the action, must not be null

Returns:

the Uni emitting null or the failure when the action completes.

pause

public io.smallrye.mutiny.Uni<Set<org.apache.kafka.common.TopicPartition>> pause()

Description copied from interface: KafkaConsumer

Pauses the consumption of records. The polling will continue, but no records will be received.

Specified by:

pause in interface KafkaConsumer<K,V>

Returns:

the Uni emitting when the action completes, the set of topic/partition paused by this call.

paused

public io.smallrye.mutiny.Uni<Set<org.apache.kafka.common.TopicPartition>> paused()

Description copied from interface: KafkaConsumer

Retrieves the set of paused topic/partition

Specified by:

paused in interface KafkaConsumer<K,V>

Returns:

the Uni emitting the set of topic/partition paused.

committed

public io.smallrye.mutiny.Uni<Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>> committed(org.apache.kafka.common.TopicPartition... tps)

Description copied from interface: KafkaConsumer

Retrieved the last committed offset for each topic/partition

Specified by:

committed in interface KafkaConsumer<K,V>

Parameters:

tps - the set of topic/partition to query, must not be null, must not be empty.

Returns:

the Uni emitting the offset for the underlying consumer for each of the passed topic/partition.

subscribe

public io.smallrye.mutiny.Multi<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> subscribe(Set<String> topics)

subscribe

public io.smallrye.mutiny.Multi<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> subscribe(Pattern topics)

resume

public io.smallrye.mutiny.Uni<Void> resume()

Description copied from interface: KafkaConsumer

Resumes the consumption of record. It resumes the consumption of all the paused topic/partition.

Specified by:

resume in interface KafkaConsumer<K,V>

Returns:

the Uni indicating when the resume action completes.

get

public String get(String attribute)

unwrap

public org.apache.kafka.clients.consumer.Consumer<K,V> unwrap()

Specified by:

unwrap in interface KafkaConsumer<K,V>

Returns:

the underlying consumer. Be aware that to use it you needs to be on the polling thread.

commit

public io.smallrye.mutiny.Uni<Void> commit(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> map)

Description copied from interface: KafkaConsumer

Commits the offsets

Specified by:

commit in interface KafkaConsumer<K,V>

Parameters:

map - the map of topic/partition -> offset to commit

Returns:

the Uni emitting null when the commit has been executed.

configuration

public Map<String,?> configuration()

close

public void close()

injectClient

public void injectClient(org.apache.kafka.clients.consumer.MockConsumer<?,?> consumer)

getPositions

public io.smallrye.mutiny.Uni<Map<org.apache.kafka.common.TopicPartition,Long>> getPositions()

Description copied from interface: KafkaConsumer

Retrieves the next positions for each assigned topic/partitions

Specified by:

getPositions in interface KafkaConsumer<K,V>

Returns:

the Uni emitting the map of topic/partition -> position.

getAssignments

public io.smallrye.mutiny.Uni<Set<org.apache.kafka.common.TopicPartition>> getAssignments()

Description copied from interface: KafkaConsumer

Retrieves the current assignments of the consumer.

Specified by:

getAssignments in interface KafkaConsumer<K,V>

Returns:

the Uni emitting the set of topic/partition currently assigned to the consumer