Package io.streamthoughts.azkarra.api.streams

Interface KafkaStreamsFactory

All Known Implementing Classes:

ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface KafkaStreamsFactory

The interface which is used for creating new KafkaStreams instance.

Field Summary

Fields

Modifier and Type	Field	Description
static KafkaStreamsFactory	DEFAULT

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.

Field Detail

DEFAULT

static final KafkaStreamsFactory DEFAULT

Method Detail

make

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.

Parameters:

topology - the Topology instance.

streamsConfig - the streams configuration.

Returns:

the KafkaStreams instance.