@Test
    public void mkStringTest() {
        Map<String, String> map = new LinkedHashMap<>();
        map.put("key1", "val1");
        map.put("key2", "val2");
        map.put("key3", "val3");
        String result = Utils.mkString(map, "__begin__", "__end__", "=", ",");
        assertEquals("__begin__key1=val1,key2=val2,key3=val3__end__", result);

        String result2 = Utils.mkString(Collections.emptyMap(), "__begin__", "__end__", "=", ",");
        assertEquals("__begin____end__", result2);
    }
Test to read content of named pipe as string. As reading/writing to a pipe can block,
timeout test after a minute (test finishes within 100 ms normally).
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java