org.springframework.kafka.test.context

Annotation Type EmbeddedKafka

@Target(value=TYPE)
 @Retention(value=RUNTIME)
 @Documented
 @Inherited
public @interface EmbeddedKafka

Annotation that can be specified on a test class that runs Spring Kafka based tests. Provides the following features over and above the regular Spring TestContext Framework:

• Registers a EmbeddedKafkaBroker bean with the EmbeddedKafkaBroker.BEAN_NAME bean name.

The typical usage of this annotation is like:

 @RunWith(SpringRunner.class)
 @EmbeddedKafka
 public class MyKafkaTests {

    @Autowired
    private EmbeddedKafkaBroker kafkaEmbedded;

    @Value("${spring.embedded.kafka.brokers}")
    private String brokerAddresses;
 }
 

Since:

1.3

Author:

Artem Bilan, Elliot Metsger, Zach Olauson, Gary Russell

See Also:

EmbeddedKafkaBroker

Optional Element Summary

Optional Elements

Modifier and Type	Optional Element and Description
java.lang.String[]	brokerProperties Properties in form key=value that should be added to the broker config before runs.
java.lang.String	brokerPropertiesLocation Spring Resource url specifying the location of properties that should be added to the broker config.
boolean	controlledShutdown
int	count
int	partitions
java.lang.String[]	topics Topics that should be created Topics may contain property placeholders, e.g.
int	value

Element Detail

value

@AliasFor(value="count")
public abstract int value

Returns:

the number of brokers

Default:

1

count

@AliasFor(value="value")
public abstract int count

Returns:

the number of brokers

Default:

1

controlledShutdown

public abstract boolean controlledShutdown

Returns:

passed into kafka.utils.TestUtils.createBrokerConfig().

Default:

false

partitions

public abstract int partitions

Returns:

partitions per topic

Default:

2

topics

public abstract java.lang.String[] topics

Topics that should be created Topics may contain property placeholders, e.g. topics = "${kafka.topic.one:topicOne}" The topics will be created with partitions() partitions; to provision other topics with other partition counts call the addTopics(NewTopic... topics) method on the autowired broker.

Returns:

the topics to create

Default:

{}

brokerProperties

public abstract java.lang.String[] brokerProperties

Properties in form key=value that should be added to the broker config before runs. Properties may contain property placeholders, e.g. delete.topic.enable=${topic.delete:true}.

Returns:

the properties to add

See Also:

brokerPropertiesLocation(), EmbeddedKafkaBroker.brokerProperties(java.util.Map)

Default:

{}

brokerPropertiesLocation

public abstract java.lang.String brokerPropertiesLocation

Spring Resource url specifying the location of properties that should be added to the broker config. The brokerPropertiesLocation url and the properties themselves may contain placeholders that are resolved during initialization. Properties specified by brokerProperties() will override properties found in brokerPropertiesLocation.

Returns:

a Resource url specifying the location of properties to add

See Also:

brokerProperties(), EmbeddedKafkaBroker.brokerProperties(java.util.Map)

Default:

""