...
Currently `ByteBufferSerializer#serialize(String, ByteBuffer)` has compatible problem, If the ByteBuffer contains only part of the ByteBuffer#capacity is 7 and only has 5 bytes data `ByteBufferSerializer#serialize(String, ByteBuffer)` will return all 7 bytes in the ByteBuffer instead of valid 5 bytes:
Code Block | ||
---|---|---|
| ||
@Test public void testByteBufferSerializer() { final byte[] bytes = "Hello".getBytes(UTF_8); final ByteBuffer buffer = ByteBuffer.allocate(7); buffer.put(bytes); try (final ByteBufferSerializer serializer = new ByteBufferSerializer()) { assertArrayEquals(bytes, serializer.serialize(topic, buffer)); } } |
...
Perform serialization tests with HeapByteBuffer/ &DirectByteBuffer of suitable and larger capacity:
...