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
Subject	getSubject(FeatureStoreBase featureStoreBase, String subjectName)
Subject	getSubject(FeatureStoreBase featureStoreBase, String subjectName, String subjectVersion)

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

getSubject

public Subject getSubject(FeatureStoreBase featureStoreBase,
                          String subjectName)
                   throws FeatureStoreException,
                          IOException

Throws:

FeatureStoreException

IOException

getSubject

public Subject getSubject(FeatureStoreBase featureStoreBase,
                          String subjectName,
                          String subjectVersion)
                   throws FeatureStoreException,
                          IOException

Throws:

FeatureStoreException

IOException