public class RegistryConsumerContainer extends ConsumerContainer<Cmmn.UUID,Str.StorageValue> implements ConsumerActions.DynamicAssignment<Cmmn.UUID,Str.StorageValue>
ConsumerContainer.DynamicPool<K,V>
ConsumerActions.DynamicAssignment<K,V>
DEFAULT_CONSUMER_POLL_TIMEOUT
Constructor and Description |
---|
RegistryConsumerContainer(Properties consumerProperties,
org.apache.kafka.common.serialization.Deserializer<Cmmn.UUID> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<Str.StorageValue> valueDeserializer,
KafkaRegistryStorageHandle handle,
Properties snapshotProperties) |
Modifier and Type | Method and Description |
---|---|
void |
start() |
void |
stop() |
isRunning, submit
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addTopicPartition, removeTopicParition
isRunning, submit
public RegistryConsumerContainer(Properties consumerProperties, org.apache.kafka.common.serialization.Deserializer<Cmmn.UUID> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<Str.StorageValue> valueDeserializer, KafkaRegistryStorageHandle handle, Properties snapshotProperties)
public void start()
start
in interface ConsumerActions<Cmmn.UUID,Str.StorageValue>
start
in class ConsumerContainer<Cmmn.UUID,Str.StorageValue>
public void stop()
stop
in interface ConsumerActions<Cmmn.UUID,Str.StorageValue>
stop
in class ConsumerContainer<Cmmn.UUID,Str.StorageValue>
Copyright © 2019 Red Hat. All rights reserved.