We must ensure that the error handling features provided by Kafka and leveraged by CKC are covered. Specifically, we must ensure we handle error reporting via DLQ well.