Configure Serdes from TestTopology

bakdata · Apr 8, 2024 · 2129eec · 2129eec
1 parent 1967dde
commit 2129eec
Showing 1 changed file with 22 additions and 0 deletions.
diff --git a/...afka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java b/...afka-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);