+
+ assertDoesNotThrow(
+ () -> endlessConsumer.exitStatus(),
+ "Consumer should not be running");
+ assertThat(endlessConsumer.exitStatus())
+ .describedAs("Consumer should have exited abnormally")
+ .containsInstanceOf(RecordDeserializationException.class);