Constructor and Description |
---|
StreamConsumerRegistrar(KinesisProxyV2Interface kinesisProxyV2Interface,
FanOutRecordPublisherConfiguration configuration,
FullJitterBackoff backoff) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Destroy any open resources used by the factory.
|
void |
deregisterStreamConsumer(String stream)
Deregister the stream consumer with the given ARN.
|
String |
registerStreamConsumer(String stream,
String streamConsumerName)
Register a stream consumer with the given name against the given stream.
|
public StreamConsumerRegistrar(KinesisProxyV2Interface kinesisProxyV2Interface, FanOutRecordPublisherConfiguration configuration, FullJitterBackoff backoff)
public String registerStreamConsumer(String stream, String streamConsumerName) throws ExecutionException, InterruptedException
stream
- the stream to register the stream consumer againststreamConsumerName
- the name of the new stream consumerExecutionException
InterruptedException
public void deregisterStreamConsumer(String stream) throws InterruptedException, ExecutionException
stream
- the stream in which to deregister the consumerExecutionException
InterruptedException
public void close()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.