@Test
void key() {

    assertThat(thread.key(new ConsumerRecord<>("topic", 0, 0, null, null)))
            .isNull();
    assertThat(thread.key(new ConsumerRecord<>("topic", 0, 0, Strings.bytes("key"), null)))
            .isEqualTo("key");
}