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