code: func (p *protoManualSyncPublisherKafka) Put(key string, message proto.Message, opts ...datasync.PutOption) error {
  	_, err := p.conn.sendSyncMessage(p.topic, p.partition, key, message, true)
  	return err
  }
docs: // Put publishes a message into kafka