code: func (conn *BytesConnectionStr) NewSyncPublisher(topic string) (BytesPublisher, error) {
  	return &bytesSyncPublisherKafka{conn, topic}, nil
  }
docs: // NewSyncPublisher creates a new instance of bytesSyncPublisherKafka that allows to publish sync kafka messages using common messaging API