An interesting model for testing with Kafka queues: instead of mocking all the components, share the whole cluster and only copy the components you need. Requires a bunch of smart routing to make it work. Testing Kafka-based Asynchronous Workflows Using OpenTelemetry