Is necessary to handle TCP packet splicing in AvroDecoder?

[kb1ns]

Hi, I have a question about the demo decoder in README.

    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
        //Do we need to handle TCP splicing here before DatumReader read?
        final NettyByteBufDecoder decoder = new NettyByteBufDecoder(in);
        final DatumReader<GenericRecord> reader = new GenericDatumReader<>(schema);
        try {
            final GenericRecord record = reader.read(null, decoder);
            out.add(record);
        } catch (final IOException e) {
            throw new RuntimeException(e);
        }
    }

[kb1ns]

I figure it out.
GenericRecord#read will keep reading according to the given schema by ByteBufDecoder's ByteBuf until all data arrived.
Is that right?

[milenkovicm]

You do need to handle TCP splicing