code: func (p *bytesManualSyncPublisherKafka) Put(key string, data []byte) error {
  	_, err := p.conn.SendSyncMessageToPartition(p.topic, p.partition, sarama.StringEncoder(key), sarama.ByteEncoder(data))
  	return err
  }
docs: // Put publishes a message into kafka