diff --git a/fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java b/fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java
index 0605854..3fdbb38 100644
--- a/fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java
+++ b/fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java
@@ -451,6 +451,28 @@ public void stop() {
         }
     }
 
+    /**
+     * Configure a {@code Serde} for values using {@link #properties}
+     * @param serde serde to configure
+     * @return configured {@code Serde}
+     * @param <T> type to be (de-)serialized
+     */
+    public <T> Serde<T> configureValueSerde(final Serde<T> serde) {
+        serde.configure(this.properties, false);
+        return serde;
+    }
+
+    /**
+     * Configure a {@code Serde} for keys using {@link #properties}
+     * @param serde serde to configure
+     * @return configured {@code Serde}
+     * @param <T> type to be (de-)serialized
+     */
+    public <T> Serde<T> configureKeySerde(final Serde<T> serde) {
+        serde.configure(this.properties, true);
+        return serde;
+    }
+
     private Properties getProperties() {
         final Properties props = new Properties();
         props.putAll(this.properties);