diff --git a/src/main/java/com/rabbitmq/stream/impl/Client.java b/src/main/java/com/rabbitmq/stream/impl/Client.java index bb8b5bc635..525731935e 100644 --- a/src/main/java/com/rabbitmq/stream/impl/Client.java +++ b/src/main/java/com/rabbitmq/stream/impl/Client.java @@ -892,7 +892,7 @@ public Response declarePublisher(byte publisherId, String publisherReference, St (publisherReference == null || publisherReference.isEmpty() ? 0 : publisherReference.length()); - if (publisherReferenceSize > 256) { + if (publisherReferenceSize >= 256) { throw new IllegalArgumentException( "If specified, publisher reference must less than 256 characters"); }