@Override
	public void updateOffset(Partition partition, long offset) {
		if (offsets != null) {
			offsets.onNext(new PartitionAndOffset(partition, offset));
		}
		else {
			delegate.updateOffset(partition, offset);
		}
	}
The timeout that {@link #close()} and {@link #destroy()} operations will wait for receving a confirmation that the
underlying writes have been processed.

@param shutdownTimeout duration in milliseconds
extensions/spring-xd-extension-kafka/src/main/java/org/springframework/integration/x/kafka/WindowingOffsetManager.java