StreamThread updateThreadMetadata(final String adminClientId) {

        threadMetadata = new ThreadMetadataImpl(
            getName(),
            state().name(),
            getConsumerClientId(getName()),
            getRestoreConsumerClientId(getName()),
            taskManager.producerClientIds(),
            adminClientId,
            Collections.emptySet(),
            Collections.emptySet());

        return this;
    }
Return information about the current {@link StreamThread}.

@return {@link ThreadMetadata}.
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java