code: func (prt *staticPartitioner) Partition(message *sarama.ProducerMessage, numPartitions int32) (int32, error) {
  	return prt.partitionID, nil
  }
docs: // Partition takes a message and partition count and chooses a partition.