Package com.bakdata.kafka.streams

Class TestTopologyFactory

java.lang.Object

com.bakdata.kafka.streams.TestTopologyFactory

public final class TestTopologyFactory
extends Object

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

Constructor Summary

Constructors

Constructor	Description
TestTopologyFactory()	Create a new TestTopologyFactory

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

TestTopologyFactory

public TestTopologyFactory()

Create a new TestTopologyFactory

Method Details

withSchemaRegistry

public static TestTopologyFactory withSchemaRegistry()

Create a new TestTopologyFactory 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 TestTopologyFactory withSchemaRegistry(TestSchemaRegistry schemaRegistry)

Create a new TestTopologyFactory with configured Schema Registry.

Parameters:

schemaRegistry - Schema Registry to use

Returns:

TestTopologyFactory with configured Schema Registry

with

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

Configure arbitrary Kafka properties for the application under test

Parameters:

kafkaProperties - properties to configure

Returns:

a copy of this TestTopologyFactory with provided properties

createTopology

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

Create a TestTopology from a ConfiguredStreamsApp. 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 - ConfiguredStreamsApp to create TestTopology from

Returns:

TestTopology that uses topology and configuration provided by ConfiguredStreamsApp

See Also:

• ConfiguredStreamsApp.getKafkaProperties(RuntimeConfiguration)
• ConfiguredStreamsApp.createTopology(Map)

createTopologyExtension

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

Create a TestTopologyExtension from a ConfiguredStreamsApp. 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 - ConfiguredStreamsApp to create TestTopology from

Returns:

TestTopologyExtension that uses topology and configuration provided by ConfiguredStreamsApp

See Also:

• ConfiguredStreamsApp.getKafkaProperties(RuntimeConfiguration)
• ConfiguredStreamsApp.createTopology(Map)

getKafkaProperties

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

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

Parameters:

app - ConfiguredStreamsApp to get Kafka properties of

Returns:

Kafka properties

See Also:

• ConfiguredStreamsApp.getKafkaProperties(RuntimeConfiguration)