Create integration-test-stack where we can feed an event to the pipeline and then read it from the other end. Use TestContainers?