@Test
void header() {

    var headers = new RecordHeaders();
    headers.add("header", Strings.bytes("value"));
    assertThat(thread.header(headers, "header")).isEqualTo("value");
    assertThat(thread.header(headers, "nonExisted")).isNull();
}