net.bluemind.core.backup.store.kafka

Class KafkaTopicSubscriber

java.lang.Object

net.bluemind.core.backup.store.kafka.KafkaTopicSubscriber

All Implemented Interfaces:

TopicSubscriber

public class KafkaTopicSubscriber
extends java.lang.Object
implements TopicSubscriber

Constructor Summary

Constructors

Constructor and Description
KafkaTopicSubscriber(java.lang.String bootstrapServer, java.lang.String topicName, com.netflix.spectator.api.Registry reg, IdFactory idFactory)

Method Summary

Modifier and Type	Method and Description
ITopicStore.IResumeToken	parseToken(io.vertx.core.json.JsonObject js)
ITopicStore.IResumeToken	subscribe(ITopicStore.IResumeToken index, RecordHandler handler)
ITopicStore.IResumeToken	subscribe(ITopicStore.IResumeToken index, RecordHandler handler, IRecordStarvationStrategy strat)
ITopicStore.IResumeToken	subscribe(RecordHandler de)
java.lang.String	topicName()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaTopicSubscriber

public KafkaTopicSubscriber(java.lang.String bootstrapServer,
                            java.lang.String topicName,
                            com.netflix.spectator.api.Registry reg,
                            IdFactory idFactory)

Method Detail

topicName

public java.lang.String topicName()

Specified by:

topicName in interface TopicSubscriber

subscribe

public ITopicStore.IResumeToken subscribe(RecordHandler de)

Specified by:

subscribe in interface TopicSubscriber

subscribe

public ITopicStore.IResumeToken subscribe(ITopicStore.IResumeToken index,
                                          RecordHandler handler)

Specified by:

subscribe in interface TopicSubscriber

subscribe

public ITopicStore.IResumeToken subscribe(ITopicStore.IResumeToken index,
                                          RecordHandler handler,
                                          IRecordStarvationStrategy strat)

Specified by:

subscribe in interface TopicSubscriber

parseToken

public ITopicStore.IResumeToken parseToken(io.vertx.core.json.JsonObject js)

Specified by:

parseToken in interface TopicSubscriber

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object