TestPatternQueuingKafka#killConsumers failing randomly

[2023-10-17T07:19:09.454Z] [ERROR] Tests run: 4, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 1.567 s <<< FAILURE! - in org.nuxeo.lib.stream.tests.pattern.TestPatternQueuingKafka
[2023-10-17T07:19:09.454Z] [ERROR] killConsumers(org.nuxeo.lib.stream.tests.pattern.TestPatternQueuingKafka)  Time elapsed: 0.376 s  <<< ERROR!
[2023-10-17T07:19:09.454Z] java.lang.NullPointerException: Cannot invoke "org.apache.kafka.clients.consumer.KafkaConsumer.wakeup()" because "this.consumer" is null
[2023-10-17T07:19:09.454Z] 	at org.nuxeo.lib.stream.log.kafka.KafkaLogTailer.close(KafkaLogTailer.java:429)
[2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
[2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179)
[2023-10-17T07:19:09.454Z] 	at java.base/java.util.concurrent.ConcurrentHashMap$KeySpliterator.forEachRemaining(ConcurrentHashMap.java:3573)
[2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
[2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
[2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
[2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
[2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
[2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
[2023-10-17T07:19:09.454Z] 	at org.nuxeo.lib.stream.log.internals.AbstractLogManager.close(AbstractLogManager.java:226)
[2023-10-17T07:19:09.454Z] 	at org.nuxeo.lib.stream.log.kafka.KafkaLogManager.close(KafkaLogManager.java:148)
[2023-10-17T07:19:09.455Z] 	at org.nuxeo.lib.stream.tests.pattern.TestPatternQueuing.closeManager(TestPatternQueuing.java:68)
[2023-10-17T07:19:09.455Z] 	at org.nuxeo.lib.stream.tests.pattern.TestPatternQueuing.resetManager(TestPatternQueuing.java:74)
[2023-10-17T07:19:09.455Z] 	at org.nuxeo.lib.stream.tests.pattern.TestPatternQueuing.killConsumers(TestPatternQueuing.java:168)