@Override
		public PartitionAndOffset call(Partition partition, Long offset) {
			return new PartitionAndOffset(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