Package com.bakdata.kafka.streams

Class TestApplicationTopologyFactory

java.lang.Object

com.bakdata.kafka.streams.TestApplicationTopologyFactory

public final class TestApplicationTopologyFactory
extends Object

Class that provides helpers for using Fluent Kafka Streams Tests with KafkaStreamsApplication

Constructor Summary

Constructors

Constructor	Description
TestApplicationTopologyFactory()	Create a new TestApplicationTopologyFactory

Method Summary

Modifier and Type	Method	Description
<K, V> com.bakdata.fluent_kafka_streams_tests.TestTopology<K,V>	createTopology(KafkaStreamsApplication<? extends StreamsApp> app)	Create a TestTopology from a KafkaStreamsApplication.
<K, V> com.bakdata.fluent_kafka_streams_tests.junit5.TestTopologyExtension<K,V>	createTopologyExtension(KafkaStreamsApplication<? extends StreamsApp> app)	Create a TestTopologyExtension from a KafkaStreamsApplication.
Map<String,Object>	getKafkaProperties(KafkaStreamsApplication<? extends StreamsApp> app)	Get Kafka properties from a KafkaStreamsApplication using a RuntimeConfiguration for test purposes with Schema Registry optionally configured.
TestApplicationTopologyFactory	with(Map<String,?> kafkaProperties)	Configure arbitrary Kafka properties for the application under test
static TestApplicationTopologyFactory	withSchemaRegistry()	Create a new TestApplicationTopologyFactory with configured Schema Registry.
static TestApplicationTopologyFactory	withSchemaRegistry(TestSchemaRegistry schemaRegistry)	Create a new TestApplicationTopologyFactory with configured Schema Registry.

Methods inherited from class java.lang.Object

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

Constructor Details

TestApplicationTopologyFactory

public TestApplicationTopologyFactory()

Create a new TestApplicationTopologyFactory

Method Details

withSchemaRegistry

public static TestApplicationTopologyFactory withSchemaRegistry()

Create a new TestApplicationTopologyFactory with configured Schema Registry. The scope is random in order to avoid collisions between different test instances as scopes are retained globally.

Returns:

TestTopologyFactory with configured Schema Registry

withSchemaRegistry

public static TestApplicationTopologyFactory withSchemaRegistry(TestSchemaRegistry schemaRegistry)

Create a new TestApplicationTopologyFactory with configured Schema Registry.

Parameters:

schemaRegistry - Schema Registry to use

Returns:

TestApplicationTopologyFactory with configured Schema Registry

with

public TestApplicationTopologyFactory with(Map<String,?> kafkaProperties)

Configure arbitrary Kafka properties for the application under test

Parameters:

kafkaProperties - properties to configure

Returns:

a copy of this TestApplicationTopologyFactory with provided properties

createTopology

public <K,
V>
com.bakdata.fluent_kafka_streams_tests.TestTopology<K,V> createTopology(KafkaStreamsApplication<? extends StreamsApp> app)

Create a TestTopology from a KafkaStreamsApplication. It injects a RuntimeConfiguration for test purposes with Schema Registry optionally configured.

Type Parameters:

K - Default type of keys

V - Default type of values

Parameters:

app - KafkaStreamsApplication to create TestTopology from

Returns:

TestTopology that uses topology and configuration provided by KafkaStreamsApplication

See Also:

• TestTopologyFactory.createTopology(ConfiguredStreamsApp)

createTopologyExtension

public <K,
V>
com.bakdata.fluent_kafka_streams_tests.junit5.TestTopologyExtension<K,V> createTopologyExtension(KafkaStreamsApplication<? extends StreamsApp> app)

Create a TestTopologyExtension from a KafkaStreamsApplication. It injects a RuntimeConfiguration for test purposes with Schema Registry optionally configured.

Type Parameters:

K - Default type of keys

V - Default type of values

Parameters:

app - KafkaStreamsApplication to create TestTopology from

Returns:

TestTopologyExtension that uses topology and configuration provided by KafkaStreamsApplication

See Also:

• TestTopologyFactory.createTopologyExtension(ConfiguredStreamsApp)

getKafkaProperties

public Map<String,Object> getKafkaProperties(KafkaStreamsApplication<? extends StreamsApp> app)

Get Kafka properties from a KafkaStreamsApplication using a RuntimeConfiguration for test purposes with Schema Registry optionally configured.

Parameters:

app - KafkaStreamsApplication to get Kafka properties of

Returns:

Kafka properties

See Also:

• TestTopologyFactory.getKafkaProperties(ConfiguredStreamsApp)