code: func (conn *BytesConnectionFields) CommitOffsets() error {
  	if conn.multiplexer != nil && conn.multiplexer.Consumer != nil {
  		return conn.multiplexer.Consumer.CommitOffsets()
  	}
  	return fmt.Errorf("cannot commit offsets, consumer not available")
  }
docs: // CommitOffsets manually commits message offsets