Uses of Class
org.axonframework.kafka.eventhandling.consumer.KafkaTrackingToken

Packages that use KafkaTrackingToken

Package	Description
org.axonframework.kafka.eventhandling.consumer

Uses of KafkaTrackingToken in org.axonframework.kafka.eventhandling.consumer

Methods in org.axonframework.kafka.eventhandling.consumer that return KafkaTrackingToken

Modifier and Type	Method and Description
KafkaTrackingToken	KafkaTrackingToken.advancedTo(int partition, long offset)
static KafkaTrackingToken	KafkaTrackingToken.emptyToken()
static KafkaTrackingToken	KafkaTrackingToken.newInstance(Map<Integer,Long> partitionPositions)

Methods in org.axonframework.kafka.eventhandling.consumer with parameters of type KafkaTrackingToken

Modifier and Type	Method and Description
static KafkaEventMessage	KafkaEventMessage.from(EventMessage<?> eventMessage, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, KafkaTrackingToken token)
static boolean	KafkaTrackingToken.isEmpty(KafkaTrackingToken token)
static boolean	KafkaTrackingToken.isNotEmpty(KafkaTrackingToken token)
static void	ConsumerUtil.seek(String topic, org.apache.kafka.clients.consumer.Consumer consumer, KafkaTrackingToken token) Subscribes the Consumer to a particular org.apache.kafka.common.internals.Topic and uses KafkaTrackingToken to update the partitions whenever a re-balance happens.
MessageStream<TrackedEventMessage<?>>	Fetcher.start(KafkaTrackingToken token) Open a stream of messages, starting at the position indicated by the given token.
MessageStream<TrackedEventMessage<?>>	AsyncFetcher.start(KafkaTrackingToken token)

Method parameters in org.axonframework.kafka.eventhandling.consumer with type arguments of type KafkaTrackingToken

Modifier and Type	Method and Description
AsyncFetcher.Builder<K,V>	AsyncFetcher.Builder.onRecordPublished(BiFunction<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,KafkaTrackingToken,Void> callback) Configure Function to invoke once a ConsumerRecord is inserted into the Buffer.