@Test
    void should_gracefully_handle_throwing_subscribers() {
        String eventLabel = "test::event::simpleThrow";
        String exceptionMessage = "0001_This is a test exception";
        RuntimeException thrownException = new RuntimeException(exceptionMessage);

        // Prepare consumer
        eventService.subscribe(eventLabel, e -> {throw thrownException;});
        Assertions.assertTrue(logs.getEvents().isEmpty());

        // Send event to throwing consumer
        eventService.sendEvent(eventLabel, "payload");
        Assertions.assertDoesNotThrow(() -> Thread.sleep(10));
        Assertions.assertTrue(logs.getEvents().stream().anyMatch(e -> e.getLevel() == Level.DEBUG && e.getThrowable() == thrownException));
    }
Test handling of event subscribers with errors
src/test/java/com/kodedu/service/impl/EventServiceTest.java