Package io.streamthoughts.azkarra.runtime.context.internal

Class ClassLoaderAwareKafkaStreamsFactory

java.lang.Object

io.streamthoughts.azkarra.runtime.context.internal.DelegatingExecutionEnvironmentAware<KafkaStreamsFactory>

io.streamthoughts.azkarra.runtime.context.internal.ClassLoaderAwareKafkaStreamsFactory

All Implemented Interfaces:

KafkaStreamsFactory, StreamsExecutionEnvironmentAware

public class ClassLoaderAwareKafkaStreamsFactory
extends DelegatingExecutionEnvironmentAware<KafkaStreamsFactory>
implements KafkaStreamsFactory

Field Summary

Fields inherited from interface io.streamthoughts.azkarra.api.streams.KafkaStreamsFactory

DEFAULT

Constructor Summary

Constructors

Constructor	Description
ClassLoaderAwareKafkaStreamsFactory(KafkaStreamsFactory delegate, ClassLoader classLoader)	Creates a new ClassLoaderAwareKafkaStreamsFactory instance.

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.streams.KafkaStreams	make(org.apache.kafka.streams.Topology topology, Conf streamsConfig)	Creates a new KafkaStreams instance for the given topology and config.

Methods inherited from class io.streamthoughts.azkarra.runtime.context.internal.DelegatingExecutionEnvironmentAware

setExecutionEnvironment

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClassLoaderAwareKafkaStreamsFactory

public ClassLoaderAwareKafkaStreamsFactory(KafkaStreamsFactory delegate,
                                           ClassLoader classLoader)

Creates a new ClassLoaderAwareKafkaStreamsFactory instance.

Parameters:

delegate - the KafkaStreamsFactory to delegate.

classLoader - the ClassLoader to be used.

Method Detail

make

public org.apache.kafka.streams.KafkaStreams make(org.apache.kafka.streams.Topology topology,
                                                  Conf streamsConfig)

Creates a new KafkaStreams instance for the given topology and config.

Specified by:

make in interface KafkaStreamsFactory

Parameters:

topology - the Topology instance.

streamsConfig - the streams configuration.

Returns:

the KafkaStreams instance.