com.logicalclocks.hsfs.metadata

Class KafkaApi

java.lang.Object

com.logicalclocks.hsfs.metadata.KafkaApi

public class KafkaApi
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaApi()

Method Summary

Modifier and Type	Method and Description
List<String>	getBrokerEndpoints(FeatureStoreBase featureStoreBase)
List<String>	getBrokerEndpoints(FeatureStoreBase featureStoreBase, boolean externalListeners)
List<PartitionDetails>	getTopicDetails(FeatureStoreBase featureStoreBase, String topicName)
Subject	getTopicSubject(FeatureStoreBase featureStoreBase, String topicName)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaApi

public KafkaApi()

Method Detail

getTopicSubject

public Subject getTopicSubject(FeatureStoreBase featureStoreBase,
                               String topicName)
                        throws FeatureStoreException,
                               IOException

Throws:

FeatureStoreException

IOException

getTopicDetails

public List<PartitionDetails> getTopicDetails(FeatureStoreBase featureStoreBase,
                                              String topicName)
                                       throws FeatureStoreException,
                                              IOException

Throws:

FeatureStoreException

IOException

getBrokerEndpoints

public List<String> getBrokerEndpoints(FeatureStoreBase featureStoreBase)
                                throws FeatureStoreException,
                                       IOException

Throws:

FeatureStoreException

IOException

getBrokerEndpoints

public List<String> getBrokerEndpoints(FeatureStoreBase featureStoreBase,
                                       boolean externalListeners)
                                throws FeatureStoreException,
                                       IOException

Throws:

FeatureStoreException

IOException