public class KafkaChangelogRestoreParams
extends java.lang.Object
Constructor and Description |
---|
KafkaChangelogRestoreParams(java.util.Map<java.lang.String,SystemConsumer> storeConsumers,
java.util.Map<java.lang.String,StorageEngine> inMemoryStores,
java.util.Map<java.lang.String,SystemAdmin> systemAdmins,
java.util.Map<java.lang.String,StorageEngineFactory<java.lang.Object,java.lang.Object>> storageEngineFactories,
java.util.Map<java.lang.String,Serde<java.lang.Object>> serdes,
MessageCollector collector) |
Modifier and Type | Method and Description |
---|---|
MessageCollector |
getCollector() |
java.util.Map<java.lang.String,StorageEngine> |
getInMemoryStores() |
java.util.Map<java.lang.String,Serde<java.lang.Object>> |
getSerdes() |
java.util.Map<java.lang.String,StorageEngineFactory<java.lang.Object,java.lang.Object>> |
getStorageEngineFactories() |
java.util.Map<java.lang.String,SystemConsumer> |
getStoreConsumers() |
java.util.Map<java.lang.String,SystemAdmin> |
getSystemAdmins() |
public KafkaChangelogRestoreParams(java.util.Map<java.lang.String,SystemConsumer> storeConsumers, java.util.Map<java.lang.String,StorageEngine> inMemoryStores, java.util.Map<java.lang.String,SystemAdmin> systemAdmins, java.util.Map<java.lang.String,StorageEngineFactory<java.lang.Object,java.lang.Object>> storageEngineFactories, java.util.Map<java.lang.String,Serde<java.lang.Object>> serdes, MessageCollector collector)
public java.util.Map<java.lang.String,SystemConsumer> getStoreConsumers()
public java.util.Map<java.lang.String,StorageEngine> getInMemoryStores()
public java.util.Map<java.lang.String,SystemAdmin> getSystemAdmins()
public java.util.Map<java.lang.String,StorageEngineFactory<java.lang.Object,java.lang.Object>> getStorageEngineFactories()
public java.util.Map<java.lang.String,Serde<java.lang.Object>> getSerdes()
public MessageCollector getCollector()