org.axonframework.kafka.eventhandling.consumer

Class ConsumerUtil

java.lang.Object

org.axonframework.kafka.eventhandling.consumer.ConsumerUtil

public class ConsumerUtil
extends Object

Utility for Consumer.

Author:

Nakul Mishra

Method Summary

Modifier and Type	Method and Description
static void	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.

Methods inherited from class java.lang.Object

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

Method Detail

seek

public static void 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.

Parameters:

topic - the topic.

consumer - the consumer.

token - the token.