docs: public Kafka sinkPartitionerCustom(Class<? extends FlinkKafkaPartitioner> partitionerClass) {
  		sinkPartitionerType = CONNECTOR_SINK_PARTITIONER_VALUE_CUSTOM;
  		sinkPartitionerClass = Preconditions.checkNotNull(partitionerClass);
  		return this;
  	}