How to print the Topology of a KStream or a KTable when you have no access to the topology

Kafka-debug.java

    private void print(Object stream) throws IllegalAccessException {
        Field field = ReflectionUtils.findField(KStreamImpl.class, "builder");
        ReflectionUtils.makeAccessible(field);
        InternalStreamsBuilder builder = (InternalStreamsBuilder) field.get(stream);

        field = ReflectionUtils.findField(InternalStreamsBuilder.class, "internalTopologyBuilder");
        ReflectionUtils.makeAccessible(field);
        InternalTopologyBuilder internalTopologyBuilder = (InternalTopologyBuilder)field.get(builder);

        TopologyDescription topologyDescription = internalTopologyBuilder.describe();

        logger.info("<TOPOLOGY> for "+ stream);
        logger.info(topologyDescription.toString());
        logger.info("</TOPOLOGY>");
    }