To support Java UnitTesting SpecMesh command/code will provision the required set of Kafka topics, it should: - parse the provided spec (async-api.spec) - provision the provided Broker instance URL endpoint with the set of required topics (requested from TestContainers as shown here https://github.com/testcontainers/testcontainers-java/blob/master/modules/kafka/src/test/java/org/testcontainers/containers/KafkaContainerTest.java) - topics will be derived by using the `spec.id` attribute, along with each `channel` that is a `publisher` (owner)