public class DefaultRecord implements Record {
// excluding key, value and headers: 5 bytes length + 10 bytes
timestamp + 5 bytes offset + 1 byte attributes
public static final int MAX_RECORD_OVERHEAD = 21;
private static final int NULL_VARINT_SIZE_BYTES =
ByteUtils.sizeOfVarint(-1);
private final int sizeInBytes;
private final byte attributes;
private final long offset;
private final long timestamp;
private final int sequence;
private final ByteBuffer key;
private final ByteBuffer value;
private final Header[] headers;
......
}
徐建海 <zero...@bytedance.com> 于2019年2月19日周二 下午7:56写道：
> As I found, the private final ByteBuffer value; is not what I passed in
> key/value pair in client, How can I get the the origin Key/Value in kafka
> server?
>
> 徐建海 <zero...@bytedance.com> 于2019年2月19日周二 下午6:51写道：
>
>> Hello:
>> I try to add some feature to Kafka, but I encounter a problem: I need
>> to get the key and value from DefaultRecord, how can I do that?
>>
>
