@Override
    public boolean equals(final Object o) {
        if (this == o) {
            return true;
        }
        if (o == null || getClass() != o.getClass()) {
            return false;
        }
        final Consumed<?, ?> consumed = (Consumed<?, ?>) o;
        return Objects.equals(keySerde, consumed.keySerde) &&
               Objects.equals(valueSerde, consumed.valueSerde) &&
               Objects.equals(timestampExtractor, consumed.timestampExtractor) &&
               resetPolicy == consumed.resetPolicy;
    }
Configure the instance of {@link Consumed} with a processor name.

@param processorName
       the processor name to be used. If {@code null} a default processor name will be generated

@return a new instance of {@link Consumed}
streams/src/main/java/org/apache/kafka/streams/kstream/Consumed.java