Uses of Interface
io.streamthoughts.azkarra.api.config.Conf
-
-
Uses of Conf in io.streamthoughts.azkarra.api
Fields in io.streamthoughts.azkarra.api declared as Conf Modifier and Type Field Description protected Conf
Executed. config
Methods in io.streamthoughts.azkarra.api that return Conf Modifier and Type Method Description Conf
StreamsExecutionEnvironment.View. config()
Conf
StreamsTopologyMeta. configuration()
Conf
AzkarraContext. getConfiguration()
Returns the global context streamsConfig of thisAzkarraContext
instance.Conf
StreamsExecutionEnvironment. getConfiguration()
Gets this environment configuration.Conf
AzkarraStreamsService. getContextConfig()
Gets the configuration ofAzkarraContext
.default Conf
StreamsLifecycleContext. streamsConfig()
Methods in io.streamthoughts.azkarra.api with parameters of type Conf Modifier and Type Method Description AzkarraContext
AzkarraContext. addConfiguration(Conf configuration)
Adds the specifiedConf
to the configuration of thisAzkarraContext
.default T
StreamsExecutionEnvironment. addConfiguration(Conf configuration)
Adds a new configuration to this environment.T
StreamsExecutionEnvironment. addFallbackConfiguration(Conf settings)
Adds settings to this environment that will be used in fallback if not present in the defined environment configuration.void
AzkarraStreamsService. addNewEnvironment(String name, String type, Conf conf)
Adds a new environment to this application.T
StreamsExecutionEnvironmentFactory. create(String name, Conf conf)
Creates a new StreamsExecutionEnvironment from the specified name and configuration.StreamsTopologyMeta.Builder
StreamsTopologyMeta.Builder. setConf(Conf conf)
AzkarraContext
AzkarraContext. setConfiguration(Conf configuration)
Sets the default configuration to be used for thisAzkarraContext
.static Executed
Executed. with(Conf conf)
Static helper that can be used to creates a newExecuted
instance with the specified streams name and configuration.Executed
Executed. withConfig(Conf config)
Returns a newExecuted
with the specified config.Method parameters in io.streamthoughts.azkarra.api with type arguments of type Conf Modifier and Type Method Description T
StreamsExecutionEnvironment. addConfiguration(Supplier<Conf> configuration)
Adds a new configuration to this environment. -
Uses of Conf in io.streamthoughts.azkarra.api.components
Methods in io.streamthoughts.azkarra.api.components that return Conf Modifier and Type Method Description Conf
ComponentDescriptor. configuration()
Gets the default configuration that will pass to the describe component if it implements theConfigurable
interface.Conf
SimpleComponentDescriptor. configuration()
Gets the default configuration that will pass to the describe component if it implements theConfigurable
interface.Conf
BaseComponentModule. getConfiguration()
Gets the configuration used by this component factory.Conf
ConfigurableComponentFactory. getConfiguration()
Gets the configuration used by this component factory.Methods in io.streamthoughts.azkarra.api.components with parameters of type Conf Modifier and Type Method Description void
SimpleComponentDescriptor. configuration(Conf configuration)
void
BaseComponentModule. configure(Conf configuration)
Configures this instance with the specifiedConf
.T
GettableComponent. get(Conf conf)
Gets the instance of typeGettableComponent
, which may be shared or independent.<T> Collection<T>
ComponentFactory. getAllComponents(Class<T> type, Conf conf)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ComponentFactory. getAllComponents(Class<T> type, Conf conf, Qualifier<T> qualifier)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ComponentFactory. getAllComponents(String type, Conf conf)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ComponentFactory. getAllComponents(String type, Conf conf, Qualifier<T> qualifier)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ContextAwareComponentFactory. getAllComponents(Class<T> type, Conf conf)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ContextAwareComponentFactory. getAllComponents(Class<T> type, Conf conf, Qualifier<T> qualifier)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ContextAwareComponentFactory. getAllComponents(String alias, Conf conf)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ContextAwareComponentFactory. getAllComponents(String alias, Conf conf, Qualifier<T> qualifier)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
DelegatingComponentFactory. getAllComponents(Class<T> type, Conf conf)
<T> Collection<T>
DelegatingComponentFactory. getAllComponents(Class<T> type, Conf conf, Qualifier<T> qualifier)
<T> Collection<T>
DelegatingComponentFactory. getAllComponents(String type, Conf conf)
<T> Collection<T>
DelegatingComponentFactory. getAllComponents(String type, Conf conf, Qualifier<T> qualifier)
<T> T
ComponentFactory. getComponent(Class<T> type, Conf conf)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ComponentFactory. getComponent(Class<T> type, Conf conf, Qualifier<T> qualifier)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ComponentFactory. getComponent(String type, Conf conf)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ComponentFactory. getComponent(String type, Conf conf, Qualifier<T> qualifier)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ContextAwareComponentFactory. getComponent(Class<T> type, Conf conf)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ContextAwareComponentFactory. getComponent(Class<T> type, Conf conf, Qualifier<T> qualifier)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ContextAwareComponentFactory. getComponent(String alias, Conf conf)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ContextAwareComponentFactory. getComponent(String alias, Conf conf, Qualifier<T> qualifier)
Gets an instance, which may be shared or independent, for the specified type.<T> T
DelegatingComponentFactory. getComponent(Class<T> type, Conf conf)
<T> T
DelegatingComponentFactory. getComponent(Class<T> type, Conf conf, Qualifier<T> qualifier)
<T> T
DelegatingComponentFactory. getComponent(String type, Conf conf)
<T> T
DelegatingComponentFactory. getComponent(String type, Conf conf, Qualifier<T> qualifier)
void
ComponentFactory. init(Conf conf)
Initialize the component factory for the given configuration.void
DelegatingComponentFactory. init(Conf conf)
-
Uses of Conf in io.streamthoughts.azkarra.api.components.condition
Methods in io.streamthoughts.azkarra.api.components.condition that return Conf Modifier and Type Method Description Conf
ConditionContext. getConfig()
Get the configuration that was passed to get the component instance.Constructor parameters in io.streamthoughts.azkarra.api.components.condition with type arguments of type Conf Constructor Description OnPropertyCondition(Function<Conf,Optional<T>> accessor, Predicate<Optional<T>> predicate)
Creates a newOnPropertyCondition
instance. -
Uses of Conf in io.streamthoughts.azkarra.api.config
Classes in io.streamthoughts.azkarra.api.config that implement Conf Modifier and Type Class Description class
AbstractConf
class
ArgsConf
AConf
which is build from a list of arguments.class
DelegatingConf
Delegates to aConf
.class
EmptyConf
class
MapConf
class
Property
A single key-value with configuration.Fields in io.streamthoughts.azkarra.api.config declared as Conf Modifier and Type Field Description protected Conf
DelegatingConf. originals
Methods in io.streamthoughts.azkarra.api.config that return Conf Modifier and Type Method Description Conf
ConfEntry. asSubConf()
Gets value as aConf
.static Conf
Conf. empty()
Static helper that can be used to creates a new emptyConf
instance.Conf
RocksDBConfig. get()
Conf
Conf. getSubConf(String path)
Gets a required parameter as aConf
.Conf
DelegatingConf. getSubConf(String path)
Gets a required parameter as aConf
.Conf
EmptyConf. getSubConf(String key)
Gets a required parameter as aConf
.Conf
MapConf. getSubConf(String path)
Gets a required parameter as aConf
.static Conf
Conf. of(Conf... configurations)
Static helper that can be used to merge multipleConf
instances.static Conf
Conf. of(String k1, Object v1)
Static helper that can be used to create a new emptyConf
instance using the specified key-value pair.static Conf
Conf. of(String k1, Object v1, String k2, Object v2)
Static helper that can be used to create a new emptyConf
instance using the specified key-value pair.static Conf
Conf. of(String k1, Object v1, String k2, Object v2, String k3, Object v3)
Static helper that can be used to create a new emptyConf
instance using the specified key-value pair.static Conf
Conf. of(String k1, Object v1, String k2, Object v2, String k3, Object v3, String k4, Object v4)
Static helper that can be used to create a new emptyConf
instance using the specified key-value pair.static Conf
Conf. of(String k1, Object v1, String k2, Object v2, String k3, Object v3, String k4, Object v4, String k5, Object v5)
Static helper that can be used to create a new emptyConf
instance using the specified key-value pair.static Conf
Conf. of(String k1, Object v1, String k2, Object v2, String k3, Object v3, String k4, Object v4, String k5, Object v5, String k6, Object v6)
Static helper that can be used to create a new emptyConf
instance using the specified key-value pair.static Conf
Conf. of(Collection<? extends Conf> configurations)
Static helper that can be used to merge multipleConf
instances.static Conf
Conf. of(Map<String,Object> map)
Conf
Conf. withFallback(Conf fallback)
Conf
DelegatingConf. withFallback(Conf fallback)
Conf
EmptyConf. withFallback(Conf fallback)
Conf
MapConf. withFallback(Conf fallback)
Methods in io.streamthoughts.azkarra.api.config that return types with arguments of type Conf Modifier and Type Method Description List<Conf>
ConfEntry. asSubConfList()
Gets value as a list ofConf
.List<Conf>
Conf. getSubConfList(String path)
Gets a required parameter as a list ofConf
.List<Conf>
DelegatingConf. getSubConfList(String path)
Gets a required parameter as a list ofConf
.List<Conf>
EmptyConf. getSubConfList(String key)
Gets a required parameter as a list ofConf
.List<Conf>
MapConf. getSubConfList(String path)
Gets a required parameter as a list ofConf
.Methods in io.streamthoughts.azkarra.api.config with parameters of type Conf Modifier and Type Method Description void
Configurable. configure(Conf configuration)
Configures this instance with the specifiedConf
.void
ConfigurableSupplier. configure(Conf configuration)
Configures this instance with the specifiedConf
.abstract T
ConfigurableSupplier. get(Conf configs)
static void
Configurable. mayConfigure(Object instance, Conf conf)
static Conf
Conf. of(Conf... configurations)
Static helper that can be used to merge multipleConf
instances.Conf
Conf. withFallback(Conf fallback)
Conf
DelegatingConf. withFallback(Conf fallback)
Conf
EmptyConf. withFallback(Conf fallback)
Conf
MapConf. withFallback(Conf fallback)
Method parameters in io.streamthoughts.azkarra.api.config with type arguments of type Conf Modifier and Type Method Description static Conf
Conf. of(Collection<? extends Conf> configurations)
Static helper that can be used to merge multipleConf
instances.Constructors in io.streamthoughts.azkarra.api.config with parameters of type Conf Constructor Description DelegatingConf(Conf originals)
Creates a newDelegatingConf
instance. -
Uses of Conf in io.streamthoughts.azkarra.api.server
Methods in io.streamthoughts.azkarra.api.server with parameters of type Conf Modifier and Type Method Description default void
AzkarraRestExtension. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.api.streams
Methods in io.streamthoughts.azkarra.api.streams that return Conf Modifier and Type Method Description protected Conf
OptimizedTopologyProvider. configuration()
ReturnsConf
defined for thisTopologyProvider
.Conf
KafkaStreamsContainer. streamsConfig()
Gets the configuration for thisKafkaStreams
instance.Methods in io.streamthoughts.azkarra.api.streams with parameters of type Conf Modifier and Type Method Description ApplicationId
ApplicationIdBuilder. buildApplicationId(TopologyMetadata metadata, Conf config)
Builds theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration.void
OptimizedTopologyProvider. configure(Conf configuration)
Configures this instance with the specifiedConf
.org.apache.kafka.streams.KafkaStreams
KafkaStreamsFactory. make(org.apache.kafka.streams.Topology topology, Conf streamsConfig)
Creates a newKafkaStreams
instance for the given topology and config. -
Uses of Conf in io.streamthoughts.azkarra.api.streams.admin
Methods in io.streamthoughts.azkarra.api.streams.admin with parameters of type Conf Modifier and Type Method Description static org.apache.kafka.clients.admin.AdminClient
AdminClientUtils. newAdminClient(Conf config)
Creates a newAdminClient
instance. -
Uses of Conf in io.streamthoughts.azkarra.http
Classes in io.streamthoughts.azkarra.http that implement Conf Modifier and Type Class Description class
ServerConfig
The server configuration.Methods in io.streamthoughts.azkarra.http with parameters of type Conf Modifier and Type Method Description void
UndertowEmbeddedServer. configure(Conf configuration)
Configures this instance with the specifiedConf
.static ServerConfigBuilder
ServerConfig. newBuilder(Conf configs)
static ServerConfig
ServerConfig. of(Conf conf)
Constructors in io.streamthoughts.azkarra.http with parameters of type Conf Constructor Description ServerConfig(Conf conf)
Creates a newSecurityConfig
instance. -
Uses of Conf in io.streamthoughts.azkarra.http.data
Methods in io.streamthoughts.azkarra.http.data that return Conf Modifier and Type Method Description Conf
GetContextResponse. getConfig()
Constructors in io.streamthoughts.azkarra.http.data with parameters of type Conf Constructor Description GetContextResponse(Conf config)
Creates a newGetContextResponse
instance. -
Uses of Conf in io.streamthoughts.azkarra.http.routes
Methods in io.streamthoughts.azkarra.http.routes with parameters of type Conf Modifier and Type Method Description void
ApiDefaultRoutes. configure(Conf configuration)
Configures this instance with the specifiedConf
.void
ApiInfoRoutes. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.http.security
Classes in io.streamthoughts.azkarra.http.security that implement Conf Modifier and Type Class Description class
SecurityConfig
The server security confiugration.Constructors in io.streamthoughts.azkarra.http.security with parameters of type Conf Constructor Description SecurityConfig(Conf conf)
Creates a newSecurityConfig
instance. -
Uses of Conf in io.streamthoughts.azkarra.http.security.auth
Methods in io.streamthoughts.azkarra.http.security.auth with parameters of type Conf Modifier and Type Method Description void
InMemoryUserIdentityManager. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.http.security.authorizer
Methods in io.streamthoughts.azkarra.http.security.authorizer with parameters of type Conf Modifier and Type Method Description void
SimpleAuthorizationManager. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.metrics
Constructors in io.streamthoughts.azkarra.metrics with parameters of type Conf Constructor Description AzkarraMetricsConfig(Conf config)
Creates a newAzkarraMetricsConfig
instance. -
Uses of Conf in io.streamthoughts.azkarra.metrics.interceptor
Methods in io.streamthoughts.azkarra.metrics.interceptor with parameters of type Conf Modifier and Type Method Description void
MeterKafkaStreamsInterceptor. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.runtime
Methods in io.streamthoughts.azkarra.runtime with parameters of type Conf Modifier and Type Method Description StreamsExecutionEnvironment<?>
StreamsExecutionEnvironmentAbstractFactory. create(String type, String name, Conf conf)
Creates a newStreamsExecutionEnvironment
for the specified type using the given name and configuration. -
Uses of Conf in io.streamthoughts.azkarra.runtime.components
Methods in io.streamthoughts.azkarra.runtime.components that return Conf Modifier and Type Method Description Conf
ComponentDescriptorBuilder. configuration()
Gets the default configuration that will pass to the describe component if it implements theConfigurable
interface.Methods in io.streamthoughts.azkarra.runtime.components with parameters of type Conf Modifier and Type Method Description ComponentDescriptorBuilder<T>
ComponentDescriptorBuilder. configuration(Conf configuration)
<T> Optional<GettableComponent<T>>
RestrictedComponentFactory. findComponentByRestriction(Class<T> componentType, Conf componentConfig, Restriction restriction)
Finds a component for the given type that is available for the given config and restriction.<T> Collection<T>
DefaultComponentFactory. getAllComponents(Class<T> type, Conf conf)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
DefaultComponentFactory. getAllComponents(Class<T> type, Conf conf, Qualifier<T> qualifier)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
DefaultComponentFactory. getAllComponents(String alias, Conf conf)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
DefaultComponentFactory. getAllComponents(String alias, Conf conf, Qualifier<T> qualifier)
Gets all instances, which may be shared or independent, for the specified type.<T> T
DefaultComponentFactory. getComponent(Class<T> type, Conf conf)
Gets an instance, which may be shared or independent, for the specified type.<T> T
DefaultComponentFactory. getComponent(Class<T> type, Conf conf, Qualifier<T> qualifier)
Gets an instance, which may be shared or independent, for the specified type.<T> T
DefaultComponentFactory. getComponent(String alias, Conf conf)
Gets an instance, which may be shared or independent, for the specified type.<T> T
DefaultComponentFactory. getComponent(String alias, Conf conf, Qualifier<T> qualifier)
Gets an instance, which may be shared or independent, for the specified type.void
DefaultComponentFactory. init(Conf conf)
Initialize the component factory for the given configuration.static ComponentDescriptorModifier
ComponentDescriptorModifiers. withConfig(Conf configuration)
Gets a modifier implementation that will set the default configuration to pass to the component if it implements theConfigurable
interface. -
Uses of Conf in io.streamthoughts.azkarra.runtime.components.condition
Methods in io.streamthoughts.azkarra.runtime.components.condition with parameters of type Conf Modifier and Type Method Description static <T> ConfigConditionalContext<T>
ConfigConditionalContext. of(Conf config)
Constructors in io.streamthoughts.azkarra.runtime.components.condition with parameters of type Conf Constructor Description ConfigConditionalContext(Conf config)
Creates a newConfigConditionalContext
instance. -
Uses of Conf in io.streamthoughts.azkarra.runtime.context
Methods in io.streamthoughts.azkarra.runtime.context that return Conf Modifier and Type Method Description Conf
DefaultAzkarraContext. getConfiguration()
Returns the global context streamsConfig of thisAzkarraContext
instance.Methods in io.streamthoughts.azkarra.runtime.context with parameters of type Conf Modifier and Type Method Description AzkarraContext
DefaultAzkarraContext. addConfiguration(Conf configuration)
Adds the specifiedConf
to the configuration of thisAzkarraContext
.void
DefaultStreamThreadExceptionHandlerFactory. configure(Conf configuration)
Configures this instance with the specifiedConf
.static DefaultAzkarraContext
DefaultAzkarraContext. create(Conf configuration)
Static helper that can be used to creates a newAzkarraContext
instance using a defaultComponentRegistry
and the specified configuration.AzkarraContext
DefaultAzkarraContext. setConfiguration(Conf configuration)
Sets the default configuration to be used for thisAzkarraContext
. -
Uses of Conf in io.streamthoughts.azkarra.runtime.context.internal
Methods in io.streamthoughts.azkarra.runtime.context.internal with parameters of type Conf Modifier and Type Method Description ApplicationId
ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder. buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)
Builds theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration.T
ContextAwareGettableComponentSupplier. get(Conf configs)
TopologyProvider
ContextAwareTopologySupplier. get(Conf configs)
org.apache.kafka.streams.KafkaStreams
ClassLoaderAwareKafkaStreamsFactory. make(org.apache.kafka.streams.Topology topology, Conf streamsConfig)
Creates a newKafkaStreams
instance for the given topology and config.org.apache.kafka.streams.KafkaStreams
ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory. make(org.apache.kafka.streams.Topology topology, Conf streamsConfig)
Creates a newKafkaStreams
instance for the given topology and config. -
Uses of Conf in io.streamthoughts.azkarra.runtime.env
Methods in io.streamthoughts.azkarra.runtime.env that return Conf Modifier and Type Method Description Conf
LocalStreamsExecutionEnvironment. getConfiguration()
Gets this environment configuration.Methods in io.streamthoughts.azkarra.runtime.env with parameters of type Conf Modifier and Type Method Description LocalStreamsExecutionEnvironment
LocalStreamsExecutionEnvironment. addFallbackConfiguration(Conf fallback)
Adds settings to this environment that will be used in fallback if not present in the defined environment configuration.ContainerId
ContainerIdBuilder. buildContainerId(ApplicationId applicationId, TopologyMetadata metadata, Conf config)
Builds the identifier that will be used for identifying theKafkaStreamsContainer
running the topology.static LocalStreamsExecutionEnvironment
LocalStreamsExecutionEnvironment. create(Conf settings)
Static helper that can be used to creates a newStreamsExecutionEnvironment
instance from the specifiedConf
and using a generated env name.static LocalStreamsExecutionEnvironment
LocalStreamsExecutionEnvironment. create(String name, Conf settings)
Static helper that can be used to creates a newStreamsExecutionEnvironment
instance from the specifiedConf
and env name.LocalStreamsExecutionEnvironment
LocalStreamsExecutionEnvironmentFactory. create(String name, Conf conf)
Creates a new StreamsExecutionEnvironment from the specified name and configuration.Optional<Supplier<ApplicationIdBuilder>>
LocalStreamsExecutionEnvironmentFactory. findApplicationIdBuilder(Conf componentConfig, Restriction restriction)
Optional<Supplier<StreamThreadExceptionHandler>>
LocalStreamsExecutionEnvironmentFactory. findStreamThreadExceptionHandler(Conf conf, Restriction restriction)
Method parameters in io.streamthoughts.azkarra.runtime.env with type arguments of type Conf Modifier and Type Method Description LocalStreamsExecutionEnvironment
LocalStreamsExecutionEnvironment. addConfiguration(Supplier<Conf> configuration)
Adds a new configuration to this environment.LocalStreamsExecutionEnvironment
LocalStreamsExecutionEnvironment. addStreamsConfiguration(Supplier<Conf> configuration)
Helper method to add a configuration prefixed with 'streams.'. -
Uses of Conf in io.streamthoughts.azkarra.runtime.env.internal
Methods in io.streamthoughts.azkarra.runtime.env.internal with parameters of type Conf Modifier and Type Method Description ContainerId
DefaultContainerIdBuilder. buildContainerId(ApplicationId applicationId, TopologyMetadata metadata, Conf config)
Builds the identifier that will be used for identifying theKafkaStreamsContainer
running the topology.T
EnvironmentAwareComponentSupplier. get(StreamsExecutionEnvironment<?> environment, Conf componentConf)
-
Uses of Conf in io.streamthoughts.azkarra.runtime.interceptors
Methods in io.streamthoughts.azkarra.runtime.interceptors that return Conf Modifier and Type Method Description Conf
AutoCreateTopicsInterceptorConfig. originals()
Methods in io.streamthoughts.azkarra.runtime.interceptors with parameters of type Conf Modifier and Type Method Description void
AutoCreateTopicsInterceptor. configure(Conf configuration)
Configures this instance with the specifiedConf
.void
KafkaBrokerReadyInterceptor. configure(Conf configs)
Configures this instance with the specifiedConf
.void
MonitoringStreamsInterceptor. configure(Conf configuration)
Configures this instance with the specifiedConf
.void
WaitForSourceTopicsInterceptor. configure(Conf configuration)
Configures this instance with the specifiedConf
.Constructors in io.streamthoughts.azkarra.runtime.interceptors with parameters of type Conf Constructor Description AutoCreateTopicsInterceptorConfig(Conf originals)
Creates a newAutoCreateTopicsInterceptorConfig
instance.KafkaBrokerReadyInterceptorConfig(Conf originals)
Creates a newKafkaBrokerReadyInterceptorConfig
instance.MonitoringStreamsInterceptorConfig(Conf originals)
Creates a newMonitoringStreamsInterceptorConfig
instance.WaitForSourceTopicsInterceptorConfig(Conf originals)
Creates a newAutoCreateTopicsInterceptorConfig
instance. -
Uses of Conf in io.streamthoughts.azkarra.runtime.interceptors.monitoring
Methods in io.streamthoughts.azkarra.runtime.interceptors.monitoring with parameters of type Conf Modifier and Type Method Description void
KafkaMonitoringReporter. configure(Conf configuration)
Configure thisStreamsMetadataReporter
.default void
MonitoringReporter. configure(Conf configuration)
Configure thisStreamsMetadataReporter
. -
Uses of Conf in io.streamthoughts.azkarra.runtime.service
Methods in io.streamthoughts.azkarra.runtime.service that return Conf Modifier and Type Method Description Conf
LocalAzkarraStreamsService. getContextConfig()
Gets the configuration ofAzkarraContext
.Methods in io.streamthoughts.azkarra.runtime.service with parameters of type Conf Modifier and Type Method Description void
LocalAzkarraStreamsService. addNewEnvironment(String name, String type, Conf conf)
Adds a new environment to this application. -
Uses of Conf in io.streamthoughts.azkarra.runtime.streams
Fields in io.streamthoughts.azkarra.runtime.streams declared as Conf Modifier and Type Field Description protected Conf
LocalKafkaStreamsContainer. streamsConfig
Methods in io.streamthoughts.azkarra.runtime.streams that return Conf Modifier and Type Method Description Conf
LocalKafkaStreamsContainer. streamsConfig()
Gets the configuration for thisKafkaStreams
instance.Methods in io.streamthoughts.azkarra.runtime.streams with parameters of type Conf Modifier and Type Method Description ApplicationId
DefaultApplicationIdBuilder. buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)
Builds theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration.LocalKafkaStreamsContainerBuilder
LocalKafkaStreamsContainerBuilder. withStreamsConfig(Conf streamsConfig)
-
Uses of Conf in io.streamthoughts.azkarra.runtime.streams.topology
Methods in io.streamthoughts.azkarra.runtime.streams.topology that return Conf Modifier and Type Method Description Conf
InternalExecuted. config()
-
Uses of Conf in io.streamthoughts.azkarra.serialization
Methods in io.streamthoughts.azkarra.serialization with parameters of type Conf Modifier and Type Method Description default void
Serdes. configure(Conf configuration)
Configure thisSerdes
. -
Uses of Conf in io.streamthoughts.azkarra.serialization.json
Methods in io.streamthoughts.azkarra.serialization.json with parameters of type Conf Modifier and Type Method Description void
ConfSerializer. serialize(Conf value, com.fasterxml.jackson.core.JsonGenerator gen, com.fasterxml.jackson.databind.SerializerProvider serializers)
-
Uses of Conf in io.streamthoughts.azkarra.streams
Methods in io.streamthoughts.azkarra.streams that return Conf Modifier and Type Method Description Conf
AzkarraApplication. getConfiguration()
Gets the configuration for thisAzkarraApplication
.Methods in io.streamthoughts.azkarra.streams with parameters of type Conf Modifier and Type Method Description AzkarraApplication
AzkarraApplication. addConfiguration(Conf configuration)
Adds the specifiedConf
to the configuration of thisAzkarraApplication
.AzkarraApplication
AzkarraApplication. setConfiguration(Conf configuration)
Sets theAzkarraApplication
configuration.AzkarraApplication
AzkarraApplication. setHttpServerConf(Conf httpServerConf)
Sets the HTTP server configuration. -
Uses of Conf in io.streamthoughts.azkarra.streams.components
Methods in io.streamthoughts.azkarra.streams.components with parameters of type Conf Modifier and Type Method Description void
ReflectMethodComponentSupplier. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.streams.config
Classes in io.streamthoughts.azkarra.streams.config that implement Conf Modifier and Type Class Description class
AzkarraConf
Methods in io.streamthoughts.azkarra.streams.config that return Conf Modifier and Type Method Description Conf
AzkarraConf. getSubConf(String key)
Gets a required parameter as aConf
.Conf
AzkarraConf. withFallback(Conf defaults)
Methods in io.streamthoughts.azkarra.streams.config that return types with arguments of type Conf Modifier and Type Method Description List<Conf>
AzkarraConf. getSubConfList(String key)
Gets a required parameter as a list ofConf
.Methods in io.streamthoughts.azkarra.streams.config with parameters of type Conf Modifier and Type Method Description Conf
AzkarraConf. withFallback(Conf defaults)
-
Uses of Conf in io.streamthoughts.azkarra.streams.config.loader.internal
Methods in io.streamthoughts.azkarra.streams.config.loader.internal that return Conf Modifier and Type Method Description Conf
EnvironmentConfig. config()
Gets the configuration for this environment.Methods in io.streamthoughts.azkarra.streams.config.loader.internal that return types with arguments of type Conf Modifier and Type Method Description Optional<Conf>
TopologyConfig. config()
Methods in io.streamthoughts.azkarra.streams.config.loader.internal with parameters of type Conf Modifier and Type Method Description static EnvironmentConfig
EnvironmentConfig. read(Conf conf)
Static helper that can be used to creates a newEnvironmentConfig
instance from the providedConf
.static TopologyConfig
TopologyConfig. read(Conf conf)
Static helper that can be used to creates a newTopologyConfig
instance from the providedConf
.TopologyConfig
TopologyConfig.Reader. read(Conf conf)
-
Uses of Conf in io.streamthoughts.examples.azkarra.dependency
Methods in io.streamthoughts.examples.azkarra.dependency with parameters of type Conf Modifier and Type Method Description void
ComplexWordCountTopology. configure(Conf configuration)
void
ConfigurableStopWordsService. configure(Conf conf)
-
Uses of Conf in io.streamthoughts.examples.azkarra.topology
Methods in io.streamthoughts.examples.azkarra.topology with parameters of type Conf Modifier and Type Method Description void
ConfigurableWordCountTopology. configure(Conf configuration)
-