I want to test the startup behaviour of a Kafka streams topology using the test-utils and TopologyTestDriver.
This does not seem to be possible to put messages on the topic and then start the topology up to consume them.
Is there any way that you can pre populate the input topic then start the topology up and test it using TopologyTestDriver?
Obviously could use something like TestContainers or KafkaJUnit but ideally do not want the overhead of those for this test.
Aucun commentaire:
Enregistrer un commentaire