diff --git a/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/implementation/ReactorShim.java b/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/implementation/ReactorShim.java index 4c068126ca26..53fa9b43ff14 100644 --- a/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/implementation/ReactorShim.java +++ b/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/implementation/ReactorShim.java @@ -80,7 +80,9 @@ private static MethodHandle lookupBackpressureWindowTimeoutOperator() { return MethodHandles.publicLookup().findVirtual(Flux.class, WINDOW_TIMEOUT_OPERATOR, MethodType.methodType(Flux.class, int.class, Duration.class, boolean.class)); } catch (IllegalAccessException | NoSuchMethodException err) { - LOGGER.verbose("Failed to retrieve MethodHandle for backpressure aware windowTimeout Reactor operator.", err); + LOGGER.verbose("Failed to retrieve MethodHandle for backpressure aware windowTimeout Reactor operator. " + + "Falling back to non-backpressure aware operator instead. " + + "Please update Reactor dependency to at least version 3.4.19.", err); } return null; }