docs: public void prepareAndCommitOffsets(Map<KafkaTopicPartition, Long> internalOffsets) throws Exception {
  		for (Map.Entry<KafkaTopicPartition, Long> entry : internalOffsets.entrySet()) {
  			KafkaTopicPartition tp = entry.getKey();
  
  			Long lastProcessedOffset = entry.getValue();
  			if (lastProcessedOffset != null && lastProcessedOffset >= 0) {
  				setOffsetInZooKeeper(curatorClient, groupId, tp.getTopic(), tp.getPartition(), lastProcessedOffset + 1);
  			}
  		}
  	}