org.apache.flink.tests.util.kafka

Class LocalStandaloneKafkaResourceFactory

java.lang.Object

org.apache.flink.tests.util.kafka.LocalStandaloneKafkaResourceFactory

All Implemented Interfaces:

KafkaResourceFactory

public final class LocalStandaloneKafkaResourceFactory
extends Object
implements KafkaResourceFactory

A KafkaResourceFactory for the LocalStandaloneKafkaResourceFactory.

Constructor Summary

Constructors

Constructor and Description
LocalStandaloneKafkaResourceFactory()

Method Summary

Modifier and Type	Method and Description
KafkaResource	create(String kafkaVersion) Returns a KafkaResource instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalStandaloneKafkaResourceFactory

public LocalStandaloneKafkaResourceFactory()

Method Detail

create

public KafkaResource create(String kafkaVersion)

Description copied from interface: KafkaResourceFactory

Returns a KafkaResource instance. If the instance could not be instantiated (for example, because a mandatory parameter was missing), then an empty Optional should be returned.

Specified by:

create in interface KafkaResourceFactory

Returns:

KafkaResource instance