File tree Expand file tree Collapse file tree 1 file changed +7
-6
lines changed
clients/src/test/java/org/apache/kafka/clients/consumer/internals Expand file tree Collapse file tree 1 file changed +7
-6
lines changed Original file line number Diff line number Diff line change @@ -213,18 +213,19 @@ public void testFailConstructor() {
213
213
props .put (ConsumerConfig .METRIC_REPORTER_CLASSES_CONFIG , "an.invalid.class" );
214
214
final ConsumerConfig config = new ConsumerConfig (props );
215
215
216
- LogCaptureAppender appender = LogCaptureAppender .createAndRegister ();
217
- KafkaException ce = assertThrows (
216
+ try ( LogCaptureAppender appender = LogCaptureAppender .createAndRegister ()) {
217
+ KafkaException ce = assertThrows (
218
218
KafkaException .class ,
219
219
() -> newConsumer (config ));
220
- assertTrue (ce .getMessage ().contains ("Failed to construct Kafka share consumer" ), "Unexpected exception message: " + ce .getMessage ());
221
- assertTrue (ce .getCause ().getMessage ().contains ("Class an.invalid.class cannot be found" ), "Unexpected cause: " + ce .getCause ());
220
+ assertTrue (ce .getMessage ().contains ("Failed to construct Kafka share consumer" ), "Unexpected exception message: " + ce .getMessage ());
221
+ assertTrue (ce .getCause ().getMessage ().contains ("Class an.invalid.class cannot be found" ), "Unexpected cause: " + ce .getCause ());
222
222
223
- boolean npeLogged = appender .getEvents ().stream ()
223
+ boolean npeLogged = appender .getEvents ().stream ()
224
224
.flatMap (event -> event .getThrowableInfo ().stream ())
225
225
.anyMatch (str -> str .contains ("NullPointerException" ));
226
226
227
- assertFalse (npeLogged , "Unexpected NullPointerException during consumer construction" );
227
+ assertFalse (npeLogged , "Unexpected NullPointerException during consumer construction" );
228
+ }
228
229
}
229
230
230
231
@ Test
You can’t perform that action at this time.
0 commit comments