@Internal public class StreamConsumerRegistrarUtil extends Object
StreamConsumerRegistrar
and handles batch
operations.Modifier and Type | Class and Description |
---|---|
static class |
StreamConsumerRegistrarUtil.FlinkKinesisStreamConsumerRegistrarException
A semantic
RuntimeException thrown to indicate errors de-/registering stream
consumers. |
Constructor and Description |
---|
StreamConsumerRegistrarUtil() |
Modifier and Type | Method and Description |
---|---|
static void |
deregisterStreamConsumers(Properties configProps,
List<String> streams)
Deregisters stream consumers for the given streams if EFO is enabled with EAGER|LAZY
registration strategy.
|
static void |
eagerlyRegisterStreamConsumers(Properties configProps,
List<String> streams)
Registers stream consumers for the given streams if EFO is enabled with EAGER registration
strategy.
|
static void |
lazilyRegisterStreamConsumers(Properties configProps,
List<String> streams)
Registers stream consumers for the given streams if EFO is enabled with LAZY registration
strategy.
|
public static void eagerlyRegisterStreamConsumers(Properties configProps, List<String> streams)
configProps
- the properties to parse configuration fromstreams
- the stream to register consumers againstpublic static void lazilyRegisterStreamConsumers(Properties configProps, List<String> streams)
configProps
- the properties to parse configuration fromstreams
- the stream to register consumers againstpublic static void deregisterStreamConsumers(Properties configProps, List<String> streams)
configProps
- the properties to parse configuration fromstreams
- the stream to register consumers againstCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.