@SuppressWarnings("WeakerAccess")
    public Map<String, String> getClientTags() {
        return originalsWithPrefix(CLIENT_TAG_PREFIX).entrySet().stream().collect(
            Collectors.toMap(
                Map.Entry::getKey,
                tagEntry -> Objects.toString(tagEntry.getValue())
            )
        );
    }
Get the configured client tags set with {@link #CLIENT_TAG_PREFIX} prefix.

@return Map of the client tags.
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java