net.bluemind.core.backup.store.kafka

Class KafkaTopicPublisher

java.lang.Object

net.bluemind.core.backup.store.kafka.KafkaTopicPublisher

All Implemented Interfaces:

TopicPublisher

public class KafkaTopicPublisher
extends java.lang.Object
implements TopicPublisher

Constructor Summary

Constructors

Constructor and Description
KafkaTopicPublisher(java.lang.String bootstrapServer, java.lang.String physicalTopic)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<java.lang.Void>	store(java.lang.String partitionToken, byte[] key, byte[] data)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaTopicPublisher

public KafkaTopicPublisher(java.lang.String bootstrapServer,
                           java.lang.String physicalTopic)

Method Detail

store

public java.util.concurrent.CompletableFuture<java.lang.Void> store(java.lang.String partitionToken,
                                                                    byte[] key,
                                                                    byte[] data)

Specified by:

store in interface TopicPublisher

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object