So far we only have mocked unit tests. However, it would make sense to add integration tests with testcontainers or embedded Kafka.