Add ability to validate Kafka failing consumers/messages

[osoykan]

Validation would seem like:

kafka {
    shouldBeFailed<Message>()
    shouldBeFailedOnCondition<Message> { actual -> actual.id == expectedId }
}

[osoykan]

Implemented in #82