code: func (p *bytesAsyncPublisherKafka) Put(key string, data []byte) error {
  	p.conn.SendAsyncMessage(p.topic, sarama.StringEncoder(key), sarama.ByteEncoder(data), nil, p.succCallback, p.errCallback)
  	return nil
  }
docs: // Put publishes a message into kafka