code: @Override
  	public TopicPartition createKafkaPartitionHandle(KafkaTopicPartition partition) {
  		return new TopicPartition(partition.getTopic(), partition.getPartition());
  	}
docs: ------------------------------------------------------------------------