@Test
void send() {

    var record = new ProducerRecord<byte[], byte[]>("topic", Strings.bytes("{}"));
    when(uri.resolveURI()).thenReturn(Boolean.FALSE);
    assertThatThrownBy(() -> producer.send(record))
            .isInstanceOf(KafkaException.class)
            .hasMessageContaining("kafka uri is not resolvable");
}