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 clientId, java.lang.String topicName)

Method Summary

Modifier and Type	Method and Description
ITopicStore.IResumeToken	parseToken(io.vertx.core.json.JsonObject js)
ITopicStore.IResumeToken	subscribe(java.util.function.BiConsumer<byte[],byte[]> de)
ITopicStore.IResumeToken	subscribe(ITopicStore.IResumeToken index, java.util.function.BiConsumer<byte[],byte[]> handler)
ITopicStore.IResumeToken	subscribe(ITopicStore.IResumeToken index, java.util.function.BiConsumer<byte[],byte[]> handler, IRecordStarvationStrategy strat)
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 clientId,
                            java.lang.String topicName)

Method Detail

topicName

public java.lang.String topicName()

Specified by:

topicName in interface TopicSubscriber

subscribe

public ITopicStore.IResumeToken subscribe(java.util.function.BiConsumer<byte[],byte[]> de)

Specified by:

subscribe in interface TopicSubscriber

subscribe

public ITopicStore.IResumeToken subscribe(ITopicStore.IResumeToken index,
                                          java.util.function.BiConsumer<byte[],byte[]> handler)

Specified by:

subscribe in interface TopicSubscriber

subscribe

public ITopicStore.IResumeToken subscribe(ITopicStore.IResumeToken index,
                                          java.util.function.BiConsumer<byte[],byte[]> 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