@Test
void handle() throws Exception {

    var key = "key";
    var message = new TestMessage();
    message.stringField = "value";
    var record = new ConsumerRecord<>("topic", 0, 0, System.currentTimeMillis(), TimestampType.CREATE_TIME,
            -1, -1, -1, Strings.bytes(key), Strings.bytes(JSON.toJSON(message)));
    record.headers().add(MessageHeaders.HEADER_TRACE, Strings.bytes("true"));
    record.headers().add(MessageHeaders.HEADER_CLIENT, Strings.bytes("client"));
    thread.handle("topic", new MessageProcess<>(messageHandler, null, TestMessage.class), List.of(record), Duration.ofHours(1).toNanos());
    verify(messageHandler).handle(eq(key), argThat(value -> "value".equals(value.stringField)));
}