@Override
    public <K, V> void forward(final K key,
                               final V value,
                               final To to) {
        final ToInternal toInternal = new ToInternal(to);
        final Record<K, V> toForward = new Record<>(
            key,
            value,
            toInternal.hasTimestamp() ? toInternal.timestamp() : timestamp(),
            headers()
        );
        forward(toForward, toInternal.child());
    }
@throws StreamsException if an attempt is made to access this state store from an unknown node
@throws UnsupportedOperationException if the current streamTask type is standby
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java