diff --git a/codec/src/main/java/io/netty/handler/codec/ByteToMessageDecoder.java b/codec/src/main/java/io/netty/handler/codec/ByteToMessageDecoder.java index 98620292b2..d61d869282 100644 --- a/codec/src/main/java/io/netty/handler/codec/ByteToMessageDecoder.java +++ b/codec/src/main/java/io/netty/handler/codec/ByteToMessageDecoder.java @@ -121,7 +121,7 @@ public abstract class ByteToMessageDecoder extends ChannelInboundHandlerAdapter composite = (CompositeByteBuf) cumulation; } else { int readable = cumulation.readableBytes(); - composite = alloc.compositeBuffer(); + composite = alloc.compositeBuffer(Integer.MAX_VALUE); composite.addComponent(cumulation).writerIndex(readable); } composite.addComponent(in).writerIndex(composite.writerIndex() + in.readableBytes());