@Test public void replaceHeader_replace() {

  record.headers().add("b3", new byte[0]);
  KafkaHeaders.replaceHeader(record.headers(), "b3", "1");
  assertThat(record.headers().lastHeader("b3").value())
      .containsExactly('1');
}