pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java [376:390]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	@Override
	public Boolean getReadCompacted() {
		return this.readCompacted;
	}

	/**
	 * Sets whether to read messages from the compacted topic rather than reading the full
	 * message backlog of the topic.
	 * @param readCompacted true to read messages from the compacted topic
	 */
	public void setReadCompacted(Boolean readCompacted) {
		this.readCompacted = readCompacted;
	}

	@Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java [142:156]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	@Override
	public Boolean getReadCompacted() {
		return this.readCompacted;
	}

	/**
	 * Sets whether to read messages from the compacted topic rather than reading the full
	 * message backlog of the topic.
	 * @param readCompacted true to read messages from the compacted topic
	 */
	public void setReadCompacted(Boolean readCompacted) {
		this.readCompacted = readCompacted;
	}

	@Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -