Package org.springframework.kafka.test

Class EmbeddedKafkaBrokerFactory

java.lang.Object

org.springframework.kafka.test.EmbeddedKafkaBrokerFactory

public final class EmbeddedKafkaBrokerFactory
extends Object

The factory to encapsulate an EmbeddedKafkaBroker creation logic.

Since:

3.2.6

Author:

Artem Bilan

Method Summary

Modifier and Type	Method	Description
static EmbeddedKafkaBroker	create(EmbeddedKafka embeddedKafka)	Create an EmbeddedKafkaBroker based on the EmbeddedKafka annotation.
static EmbeddedKafkaBroker	create(EmbeddedKafka embeddedKafka, Function<String,String> propertyResolver)	Create an EmbeddedKafkaBroker based on the EmbeddedKafka annotation.

Methods inherited from class java.lang.Object

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

Method Details

create

public static EmbeddedKafkaBroker create(EmbeddedKafka embeddedKafka)

Create an EmbeddedKafkaBroker based on the EmbeddedKafka annotation.

Parameters:

embeddedKafka - the EmbeddedKafka annotation.

Returns:

a new EmbeddedKafkaBroker instance.

create

public static EmbeddedKafkaBroker create(EmbeddedKafka embeddedKafka,
 Function<String,String> propertyResolver)

Create an EmbeddedKafkaBroker based on the EmbeddedKafka annotation.

Parameters:

embeddedKafka - the EmbeddedKafka annotation.

propertyResolver - the Function for placeholders in the annotation attributes.

Returns:

a new EmbeddedKafkaBroker instance.