- Map<String, Object> propertyMap = serializationConfig();
-
- Properties properties = new Properties();
- properties.putAll(propertyMap);
-
- JsonSerde<?> keySerde = new JsonSerde<>();
- keySerde.configure(propertyMap, true);
- JsonSerde<?> valueSerde = new JsonSerde<>();
- valueSerde.configure(propertyMap, false);
-
- testDriver = new TopologyTestDriver(topology, properties);