Package com.logicalclocks.hsfs.metadata

Class KafkaApi

java.lang.Object

com.logicalclocks.hsfs.metadata.KafkaApi

public class KafkaApi
extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaApi()

Method Summary

Modifier and Type	Method	Description
Subject	getSubject(FeatureStoreBase featureStoreBase, String subjectName)
Subject	getSubject(Integer featureStoreId, String subjectName)
Subject	getSubject(Integer featureStoreId, String subjectName, String subjectVersion)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaApi

public KafkaApi()

Method Details

getSubject

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

Throws:

FeatureStoreException

IOException

getSubject

public Subject getSubject(Integer featureStoreId,
 String subjectName)
                   throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

getSubject

public Subject getSubject(Integer featureStoreId,
 String subjectName,
 String subjectVersion)
                   throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException